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。