Re: Kafka Connect behaves weird in case of zombie Kafka brokers. Also, zombie brokers?

2017-04-09 Thread Ewen Cheslack-Postava
Is that node the only bootstrap broker provided? If the Connect worker was pinned to *only* that broker, it wouldn't have any chance of recovering correct cluster information from the healthy brokers. It sounds like there was a separate problem as well (the broker should have figured out it was

Kafka Connect behaves weird in case of zombie Kafka brokers. Also, zombie brokers?

2017-03-21 Thread Anish Mashankar
Hello everyone, We are running a 5 broker Kafka v0.10.0.0 cluster on AWS. Also, the connect api is in v0.10.0.0. It was observed that the distributed kafka connector went into infinite loop of log message of (Re-)joining group connect-connect-elasticsearch-indexer. And after a little more