Kafkacat无法向主题发送消息

Question

我是Apache Kafka和Kafkacat的新手，试图从这里学习新东西: time 17:32的https://www.youtube.com/watch?v=5Mgni6AYnWg&t=123s。

我在我的远程虚拟机上设置了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

Answer 1

因为它看起来像是您在一个名为toUpperCase-in-0的主题中写入内容，而从另一个toUpperCase-out-0中读取内容

不需要将数据从toUpperCase-in-0主题移动到toUpperCase-out-0中。

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