我在kafka docs中读过:Kafka还有一个命令行使用者,它会将消息转储到标准输出 .
bin / kafka-console-consumer.sh --zookeeper localhost:2181 - topic test - from-beginning
我想知道如果我想消费者消息并将它们推送到另一个输出,那么要添加到上述命令的选项 . kafka-console-consumer没有--help选项,我找不到任何参数,命令选项 .
谢谢
除非您想要下载和修改代码,否则默认使用者只能输出到控制台 .
编写简单的使用者并输出到其他格式或使用它做其他事情非常容易 .
示例代码列于https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example
1 回答
除非您想要下载和修改代码,否则默认使用者只能输出到控制台 .
编写简单的使用者并输出到其他格式或使用它做其他事情非常容易 .
示例代码列于https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example