最近、テスト用の Kafka クラスターをセットアップしました。私はアイテムを聞いている消費者グループを運営していますが、うまくいっているようです。コンシューマ グループの名前は ですdefault
。驚いたことに、消費者グループをリストすると、空のリストが表示されます。
$ ./bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --list
$
また、オフセットを明示的にクエリしても何も得られません。
$ ./bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group default
No topic available for consumer group provided
GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER
kafka-consumer-groups.sh —new-consumer
オフセットを追跡できるようにするために、コンシューマー グループを手動で作成する必要がありますか?