Kafka 10 kafka-consumer-groups.sh与Kafka 8 kafka-run-class.sh ConsumerOffsetChecker

Question

我需要在Kafka 10中给我的消费者命名，就像我在Kafka 8中所做的一样，因为我有脚本可以嗅出并进一步使用此信息。

显然，consumer.id的默认命名已经更改（现在它也单独显示client.id）。我没有看到在文档中提到或比较这一点。

在卡夫卡10点而言，什么是我需要做的，有它产生相同的“<组><主机> ...”消费者和/或客户端ID格式卡夫卡8当量（而不是'consumer - ＃ - < guid>'格式如下所示）？

卡夫卡8：

/usr/local/kafka-0.8/bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zkconnect localhost:2181 --group optimizer-group --topic optimizer-default-topic 

Group   Topic       Pid Offset   logSize   Lag    Owner 
optimizer-group optimizer-default-topic  0 17059718  17059725  7    my-group_myhost.com-1497048808577-1575fa11-0 
... 

卡夫卡10：0.8

/usr/local/kafka/bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group optimizer-group --describe 

TOPIC       PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG  CONSUMER-ID          HOST       CLIENT-ID 
eddude-error-topic    0   0    0    0   consumer-2-e839517b-a150-498d-9054-31ec7a655936 /10.xxx.xx.xxx     consumer-2 
... 

Answer 1

默认消费者ID命名约定是主机名timestamp- [最显著8 UUID位虽然你可以设置consumer.id到重写它。

但是，0.10中的默认消费者ID更改为[client.id] - [UUID]，似乎没有办法直接指定它。唯一的方法是设置client.id间接设置消费者ID。