使用来自 Kafka 主题的消息并将它们存储在目录 /tmp/kafka-messages答案

【问题标题】：Consume the messages from Kafka topic and store them in a directory /tmp/kakfa-messages使用来自 Kafka 主题的消息并将它们存储在目录 /tmp/kafka-messages
【发布时间】：2020-12-06 22:27:29
【问题描述】：

在以下步骤中需要帮助，了解如何使用来自 Kafka 主题的消息并将它们存储在目录 /tmp/kakfa-messages 中

问题陈述：

创建一个 kafka 消费者来消费来自主题“Multibrokerapplication”的消息并将它们存储在“/tmp/kafka-messages”中

第 1 步：我可以使用发布到主题“Multibrokerapplication”的消息，如下所示。

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

但是，如何通过命令行将它们存储在文件夹 /tmp/kafka-messages 中的第二步？

你能推荐一下吗？

谢谢

【问题讨论】：

您可以简单地将输出重定向到所需位置。你能详细说明你试图用这个逻辑解决的问题吗？

标签： apache-kafka

【解决方案1】：

输出重定向

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

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

【讨论】：