I am working with tkafka components and everything is good when all is working good. When i trying to test the error scenario, i turned down a kafka node, when the job was reading messages, and the talend job hanged. I tried to provide various possibilities but unable to make it work. The other running kafka node has all the messages, but talend is unable to read from it..
Could anyone give some pointers or help
How did you set your broker list in tKafkaInput? Could you please post your tKafkaInput component setting screenshots on forum?