Я пытаюсь описать группу потребителей kafka с помощью следующей команды в терминале:
./kafka-consumer-groups.sh --bootstrap-server $IP:$PORT --describe --group $GROUPID
Я могу получить $GROUPID
с помощью этой команды:
./kafka-consumer-groups.sh --bootstrap-server $IP:$PORT --list
и ответ:
b'TestProcess'
Но после попытки получить подробную информацию об этой группе с помощью этой команды:
./kafka-consumer-groups.sh --bootstrap-server $IP:$PORT --describe --group TestProcess
появится такой результат:
Error: Consumer group 'TestProcess' does not exist.
Кафка Версия: 2.2.0
Похоже, ваша группа потребителей названа буквально b'TestProcess'
, поэтому попробуйте выполнить команду описания следующим образом:
./kafka-consumer-groups.sh --bootstrap-server $IP:$PORT --describe --group "b'TestProcess'"