Hi

I have simple topology Kafka consumer (Spout) and HBase writer (bolt)

Sometimes some messages getting failed status. Most of time topology works well but I'd like to know what is exact reason why message fails. As much I have read there is timeout (default 30s) when message fails. But this is not enough. I need to know where is bottleneck to improve. Timeouts appears behind spout. As much I understand Spout gets ack in case message is fully processed by topology.
So the question is where to dig ?

--
Margus (margusja) Roo
http://margus.roo.ee
skype: margusja
+372 51 480

Reply via email to