Hi Everyone,

I am encountering this exception similar to Saurabh's report earlier today
as I try to scale up a Storm -> Kafka output via the KafkaBolt (i.e., add
more KafkaBolt executors).

Question...does this necessarily indicate back pressure from Kafka where
the Kafka writes cannot keep up with the incoming messages sent over by
Storm? If so, do I add brokers to the cluster, do I add more topics, a
combo thereof or something else?

As always, any thoughts from people who know more than I do are
appreciated. :)

Thanks

--John

Reply via email to