Не удается найти тему при создании сообщений: 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) ....

Может кто-нибудь, пожалуйста, помогите? Благодарю.

Ответы на вопрос(1)

Ваш ответ на вопрос