Can you extend the auto.commit.interval.ms to 5000 ? and retry? Also, why is your port set to 0?
Regards, On Wed, 29 Aug 2018 at 14:25, Cristian Petroaca <cpetro...@fitbit.com.invalid> wrote: > Hi, > > I’m using the Kafka lib with version 2.11_1.0.1. > I use the KafkaServer.scala class to programmatically create a Kafka > instance and connect it to a programmatically created Zookeeper instance. > It has the following properties: > host.name", "127.0.0.1" > "port", "0" > "zookeeper.connect", "127.0.0.1:" + zooKeeperPort > "broker.id", "1" > auto.create.topics.enable", "true" > "delete.topic.enable", "true" > > I then create a new Kafka Consumer with the following properties: > bootstrap.servers", “127.0.0.1” + kafkaPort > "auto.commit.interval.ms", "10" > “client_id”, “xxxx” > “enable.auto.commit”, “true” > “auto.commit.interval.ms”, “10” > > My problem is that after I subscribe the consumer to a custom topic, the > consumer just blocks in the .poll() method and I see a lot of messages like: > “Group coordinator lookup failed: The coordinator is not available.” > > I read on another forum that a possible problem is that the > _consumer_offsets topic doesn’t exist but that’s not the case for me. > > Can you suggest a possible root cause? > > Thanks, > Cristian >
