In my previous post, I introduced a simple Apache Flink example, which just listens to a port and streams whatever the data posts on that port. Now, it is time to see a more realistic example.
You may also like: Kafka Producer and Consumer Examples Using Java
In the real world, we publish our streaming data to queue-like structures; it may be a JMS queue or Kafka topic.