Kafka消费者指定输出

tct7dpnv  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(351)

我在kafka文档中读到过:kafka还有一个命令行使用者,它将消息转储到标准输出。
bin/kafka-console-consumer.sh--缩放器localhost:2181 --topic 测试--从头开始
我想知道,如果我想使用消息并将它们推送到另一个输出,那么需要向上述命令添加哪些选项。kafka控制台使用者没有--help选项,我找不到任何参数,命令的选项。
谢谢您

vom3gejh

vom3gejh1#

默认使用者只能输出到控制台,除非您想下载并修改代码。
很容易编写一个简单的使用者,并将其输出为其他格式或使用它做其他事情。
示例代码列在https://cwiki.apache.org/confluence/display/kafka/consumer+group+example

相关问题