topology - Kafka Spout fails to acknowledge message in storm while setting multiple workers -
i have storm topology subscribes events kafaka queue. topology works fine while number of workers config.setnumworkers set 1. when update number of workers more 1 or 2, kafkaspout fails acknowledge messages while looking @ storm ui. might possible cause, not able figure out, exactness of problem.
i have 3 node cluster running 1 nimbus , 2 supervisors.
my problem got resolve. reason being kafka unable acknowledge spout message conflict hostname. had mistakenly same host name in /etc/hostname , /etc/hosts file of both workers. when check worker able exception - unable communicate host. there figured out, problem was host name .i updated host name in etc/hosts mapping , /etc/host name file. message started acknowledged. thank you.
Comments
Post a Comment