2018-11-08 11:08:43 UTC
I am using TCP communication to have 2 topologies communicate with each
Below is an overview of the topologies:
Spout -> BoltA1 -> BoltA2 -> TCPProducerBolt (ex: port 5555 on a server).
Topology02( This receives data from the TCP port from the above topology.
Has a while loop to receive the data from TCP ):
TCPConsumerSpout -> BoltB1 -> BoltB2
I am afraid that if the tcp messages are too many for the BoltB1 to handle,
there may be know way to slow it down.
I need to know the number of pending messages in BoltB1 so that I can think
of somehow throttling TCPProducerBolt.
Kindly let me know if you have any suggestions.