需要以下步骤的帮助吗？如何使用kafka主题中的消息并将它们存储在/tmp/kakfa messages目录中
问题陈述：
创建一个kafka使用者来使用主题“multibrokerapplication”中的消息，并将它们存储在“/tmp/kafka messages”中
步骤1：我可以使用发布到主题“multibrokerapplication”的消息，如下所示。
bin/kafka-console-consumer.sh—引导服务器localhost:9092 --topic 多代理应用程序-从头开始
但是，如何实现通过命令行将它们存储在文件夹/tmp/kafka消息中的第二步呢？
你能建议一下吗？
谢谢
1条答案
按热度按时间fzwojiic1#
输出重定向
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic Multibrokerapplication —from-beginning >> /tmp/kafka-messages但我建议你试试connect-standalone命令FileSinkConnector班