使用Kafka主题中的消息,并将它们存储在/tmp/kafa-messages目录中



如何使用Kafka主题中的消息并将其存储在/tmp/kafa-messages 目录中的以下步骤需要帮助

问题说明:

创建一个kafka使用者以使用主题"Multibrokerapplication"中的消息,并将其存储在"/tmp/kafka messages"中

步骤1:我可以使用发布到主题"Multibrokerapplication"的消息,如下所示。

bin/kafka-console-consumer.sh--引导服务器localhost:9092--主题Multibrokerapplication--从开始

但是,如何通过命令行实现将它们存储在文件夹/tmp/kafka消息中的第二步?

你能提出建议吗?

感谢

输出重定向

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic Multibrokerapplication —from-beginning >> /tmp/kafka-messages

但我建议您尝试将connect-standalone命令与FileSinkConnector类一起使用

最新更新