我在kafka文档中读到: Kafka也有一个命令行使用者将消息转储到标准输出。kafka消费者指定的输出
斌/ kafka-console-consumer.sh --zookeeper本地主机:2181 --topic测试--from-开始
我不知道,如果我想消费者信息和他们推到另一个输出,要添加到上述命令的选项。 kafka-console-consumer没有--help选项,我找不到任何参数,命令选项。
谢谢
我在kafka文档中读到: Kafka也有一个命令行使用者将消息转储到标准输出。kafka消费者指定的输出
斌/ kafka-console-consumer.sh --zookeeper本地主机:2181 --topic测试--from-开始
我不知道,如果我想消费者信息和他们推到另一个输出,要添加到上述命令的选项。 kafka-console-consumer没有--help选项,我找不到任何参数,命令选项。
谢谢
默认的消费者只能输出到控制台,除非你想下载和修改代码。
写一个简单的消费者和输出到其他格式或使用其他格式很容易。
一个示例代码在https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example上市
有人帮我 – Jin