如何解决消耗来自Kafka主题的消息,并将它们存储在目录/ tmp / kakfa-messages
在以下步骤中需要帮助,如何使用来自Kafka主题的消息并将其存储在目录/ tmp / kakfa-messages
问题陈述:
创建一个kafka使用者以使用主题“ Multibrokerapplication”中的消息并将其存储在“ / tmp / kafka-messages”中
步骤1:我可以使用发布到主题“ Multibrokerapplication”的消息,如下所示。
bin / kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic Multibrokerapplication —从头开始
但是,如何实现通过命令行将它们存储在/ tmp / kafka-messages文件夹中的第二步?
可以请你建议吗?
谢谢
解决方法
输出重定向
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic Multibrokerapplication —from-beginning >> /tmp/kafka-messages
但是我建议您尝试对connect-standalone
类使用FileSinkConnector
命令
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。