como definir o nome do grupo ao consumir mensagens no kafka usando a linha de comando
Alguma idéia de como definir o nome do grupo ao consumir mensagens no kafka usando a linha de comando.
Eu tentei com o seguinte comando:
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic nil_RF2_P2 --from-beginning --config group.id=test1
'config' is not a recognized option
O objetivo é encontrar o deslocamento das mensagens consumidas com o seguinte comando:
bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper localhost:2181 --group test1
Alguém pode ajudar nesse sentido !!
Desde já, obrigado !!