Wie man den Gruppennamen festlegt, wenn man Nachrichten in kafka über die Kommandozeile konsumiert
Eine Idee, wie Sie den Gruppennamen festlegen, wenn Sie Nachrichten in kafka über die Befehlszeile empfangen.
Ich habe es mit dem folgenden Befehl versucht:
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic nil_RF2_P2 --from-beginning --config group.id=test1
'config' is not a recognized option
Das Ziel besteht darin, den Versatz der verbrauchten Nachrichten mit dem folgenden Befehl zu ermitteln:
bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper localhost:2181 --group test1
Kann jemand in dieser Hinsicht helfen !!
Danke im Voraus !