我在kafka文档中读到过：kafka还有一个命令行使用者，它将消息转储到标准输出。bin/kafka-console-consumer.sh--缩放器localhost:2181 --topic 测试--从头开始我想知道，如果我想使用消息并将它们推送到另一个输出，那么需要向上述命令添加哪些选项。kafka控制台使用者没有--help选项，我找不到任何参数，命令的选项。谢谢您
vom3gejh1#
默认使用者只能输出到控制台，除非您想下载并修改代码。很容易编写一个简单的使用者，并将其输出为其他格式或使用它做其他事情。示例代码列在https://cwiki.apache.org/confluence/display/kafka/consumer+group+example
1条答案
按热度按时间vom3gejh1#
默认使用者只能输出到控制台，除非您想下载并修改代码。
很容易编写一个简单的使用者，并将其输出为其他格式或使用它做其他事情。
示例代码列在https://cwiki.apache.org/confluence/display/kafka/consumer+group+example