Kafkacat 无法向主题发送消息

如何解决Kafkacat 无法向主题发送消息

我是 Apache Kafka 和 kafkacat 的新手，我试图从这里学习新事物：https://www.youtube.com/watch?v=5Mgni6AYnWg&t=123s 在时间 17:32。

我在远程 VM 上设置了 kafka 和 kafkacat。

[user@user bin]$ ./kafka-topics.sh --list --zookeeper localhost:2181
__consumer_offsets
quickstart-events
test
toupperCase-in-0
toupperCase-out-0
users-log

当我在 kafkacat 上输入一些数据时，另一面没有打印任何内容。

[user@user bin]$ kafkacat -b localhost:9092 -t toupperCase-in-0 -P
Hello
hey
Hie
Howdy
John
Sam

另一个术语

[user@user ~]kafkacat -b localhost:9092 -t toupperCase-out-0                   
% Auto-selecting Consumer mode (use -P or -C to override)
% Reached end of topic toupperCase-out-0 [0] at offset 0

可能是什么问题？

[user@userbin]$ ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic toupperCase-in-0 --from-beginning

解决方法

看起来您正在写一个名为 toUpperCase-in-0 的主题并从另一个主题中读取 toUpperCase-out-0

没有将数据从 toUpperCase-in-0 主题移入 toUpperCase-out-0。

kafka 不会为你移动数据，当你插入一个主题时，你需要一些东西来读取它并移动它（就像另一个进程那样），它不像管道，而是一个日志文件