Блог

Я совершенно новичок в Кафке и следую учебнику Стефана Маарека. Я пытаюсь собрать данные для Кафки. Мой порт Zookeeper 2181 и имеет тему: первая тема.

 Topic: first-topic      TopicId: AiYAVfKyQxm3827NoYI8sw PartitionCount: 3     ReplicationFactor: 1    Configs:
        Topic: first-topic      Partition: 0    Leader: 0       Replicas: 0     Isr: 0
        Topic: first-topic      Partition: 1    Leader: 0       Replicas: 0     Isr: 0
        Topic: first-topic      Partition: 2    Leader: 0       Replicas: 0     Isr: 0
 

Я пытаюсь получить данные по команде:

 kafka-console-producer --broker-list 120.0.0.1:9092 --topic first-topic
 

Но я продолжаю получать ошибки:

 
[2021-08-15 14:36:27,204] WARN [Producer clientId=console-producer] Bootstrap broker 120.0.0.1:9092 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)
[2021-08-15 14:36:48,373] WARN [Producer clientId=console-producer] Connection to node -1 (/120.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
[2021-08-15 14:37:18,179] ERROR Error when sending message to topic first-topic with key: null, value: 1 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: Topic first-topic not present in metadata after 60000 ms.
[2021-08-15 14:39:15,333] WARN [Producer clientId=console-producer] Bootstrap broker 120.0.0.1:9092 (id: -1 rack: null) disconnected (org.apache.kafka.clients.NetworkClient)
 

Я проверил все сообщения, но они не имеют для меня смысла. Кто-нибудь может, пожалуйста, подсказать, что я могу сделать?

Спасибо.

Я только что снова установил Кафку. На данный момент это обходной путь, но не решение. Надеюсь, кто-нибудь подскажет правильный способ.