I have a 3 node Kafka cluster. And the following properties are set in
server.properties:

offsets.topic.replication.factor=3
default.replication.factor=3
min.insync.replicas=2

In one terminal, I ran the following commands:

bin/kafka-topics --zookeeper localhost:2181 --create
--replication-factor 3 --partitions 1 --topic test-topic
bin/kafka-console-consumer --bootstrap-server localhost:9092 --topic
test-topic --offset earliest --partition 0

In another terminal, I ran this command:

bin/kafka-console-producer --broker-list localhost:9092 --topic test-topic

After a while, the following error will keep popping out in the second
terminal:

[2018-07-18 17:09:06,255] ERROR [Consumer clientId=consumer-1,
groupId=console-consumer-61589] Offset commit failed on partition
test-topic-0 at offset 2: The coordinator is not available.
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)

After I added the following property to server.properties, the error
disappeared:

offsets.topic.replication.factor=3

I think that it is better to document the relation between such properties.

-- 
Jingguo

Reply via email to