0

我是 Apache Kafka 和 Kafkacat 的新手，试图从这里学习新事物：https ://www.youtube.com/watch?v=5Mgni6AYnWg&t=123s at time 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
4

1 回答 1

0

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

没有将数据从toUpperCase-in-0主题移动到toUpperCase-out-0.

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

于 2021-03-15T19:55:46.797 回答