Question

Since blocking process isn't allowed in Spouts, What is the best approach to implement a Spout as Socket listener to recieve DataGram Packets?

Was it helpful?

Solution

One of the most famous software development rules is:

We can solve any problem by introducing an extra level of indirection

You can simply send your datagram packets to something like Apache Kafka, HornetQ, RabbitMQ and your Spout will pull the data from there.

Licensed under: CC-BY-SA with attribution
Not affiliated with StackOverflow
scroll top