Не удается найти тему при создании сообщений: UNKNOWN_TOPIC_OR_PARTITION
У меня есть двухузловой кластер kafka (экземпляры EC2), где каждый узел используется как отдельный брокер. Когда я запускаю продюсера на экземпляре лидера с помощью следующей команды:
kafka-console-producer.sh --broker-list localhost:9092 --topic test
Я получаю следующие ошибки.
тестовое сообщение [2017-01-09 13: 22: 39,483] ПРЕДУПРЕЖДЕНИЕ Ошибка при получении метаданных с идентификатором корреляции 0: {test = UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient) [2017-01-09 13:22: 39,562] WARN Ошибка при получении метаданных с идентификатором корреляции 1: {test = UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient) [2017-01-09 13: 22: 39,663] WARN Ошибка при получении метаданных с корреляционным идентификатором 2: {test = UNKNOWN_TOPIC_OR_PARTITION} (org.apache.kafka.clients.NetworkClient) ...
Перечисление тем сkaka-topics.sh
показывает, что тема существует.
Описание темы с:
kafka-topics.sh --zookeeper localhost:2181 --describe --topic test
возвращается
Topic:test PartitionCount:8 ReplicationFactor:1 Configs:
Topic: test Partition: 0 Leader: 1 Replicas: 1 Isr: 1
Topic: test Partition: 1 Leader: 2 Replicas: 2 Isr: 2
Topic: test Partition: 2 Leader: 1 Replicas: 1 Isr: 1
Topic: test Partition: 3 Leader: 2 Replicas: 2 Isr: 2
Topic: test Partition: 4 Leader: 1 Replicas: 1 Isr: 1
Topic: test Partition: 5 Leader: 2 Replicas: 2 Isr: 2
Topic: test Partition: 6 Leader: 1 Replicas: 1 Isr: 1
Topic: test Partition: 7 Leader: 2 Replicas: 2 Isr: 2
Я использую Кафку 0.10.1.1.
server.propertes
файл содержит:
listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://0.0.0.0:9092
port=9092
host.name=kafka-node1(kafka-node1 for the second host)
advertised.host.name=kafka-node1(kafka-node2 for the second host)
advertised.port=9092
Когда я пытаюсь создать сообщения со второго хоста, я получаю сообщение ниже:
ПРЕДУПРЕЖДЕНИЕ. Произошла ошибка при получении ответа с идентификатором корреляции 1 в разделе раздела test-4, повторная попытка (осталось 2 попытки). Ошибка: NOT_LEADER_FOR_PARTITION (org.apache.kafka.clients.producer.internals.Sender) ....
Может кто-нибудь, пожалуйста, помогите? Благодарю.