我在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