Question

Kafka Consumer is not throwing errors even though if i provide wrong broker details in Java Standalone

The polling is happening continuously , it should throw errors

Broker connectivity check is not happening

Answer 1

Hi@srinivas,

This is because the PID file is still available in your log. So try to remove your previous PID file and run again.

Answer 2

Please delete all log files. Reason behind, on local system frequently new learners start many broker alternatively which is not good practice to run cluster. Always, need to map our broker cluster with different zookeeper. Practically it runs on independent system.