问题描述
我是 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 不会为你移动数据,当你插入一个主题时,你需要一些东西来读取它并移动它(就像另一个进程那样),它不像管道,而是一个日志文件