使用Kafkacat设置Kafka生产者和消费者时出现错误

Question

使用这些命令设置kafka服务器，然后构建一个基本的生产者-消费者模型，用于从生产者向消费者发送问候。

brew services start zookeeper
brew services start kafka
kcat -P -b localhost:9092 -t topic1 
kcat -C -b localhost:9092 -t topic1 -o beginning

在单独的终端中运行消费者代码时出现此错误。

ERROR: Topic topic1 error: Broker: Unknown topic or partition

Answer 1

您还没有实际生成任何消息，因此没有创建该主题。kcat -P从控制台读取输入，并将其发送到Kafka，在这种情况下，您不会发送任何内容。

例如，这些命令：

echo "My Message" | kcat -P -b localhost:9092 -c 1 -t some-topic
kcat -C -b localhost:9092 -t some-topic

将生成以下输出：

My Message
% Reached end of topic some-topic [0] at offset 1