我正在尝试通过以下命令在终端中描述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.
kafka版本:2.2.0
看起来您的消费者组名为b'TestProcess'
,因此请尝试发出以下命令:
./kafka-consumer-groups.sh --bootstrap-server $IP:$PORT --describe --group "b'TestProcess'"