如何为新的Kafka消费者设置consumer.id

Question

根据文档，旧版消费者配置包括默认设置为 null 的consumer.id：

consumer.id
默认值：null
描述：如果未设置，则自动生成。

对于新版 Kafka 消费者，是否可以设置consumer.id？如果可以，如何实现？

- Giorgos Myrianthous

---

我想你在谈论消费者组ID？ - Raman Mishra

@RamanMishra 还有一个 consumer.id。 - Giorgos Myrianthous

你用这个做什么？也许可以被 client.id 替换掉吗？ - Thilo

当运行命令kafka-consumer-groups --bootstrap-server localhost:9092 --group group_name --describe时，我希望获得一个更有意义的consumer.id，而不是让Kafka生成一个长而随机的标识符。client.id可以改变consumer.id的前一部分，但它不能完全替换它。例如，如果我将client.id设置为abc，那么consumer.id将变成类似于abc-12kdl12-....的形式。 - Giorgos Myrianthous

@GiorgosMyrianthous，你找到解决方法了吗？ - Meidan Alon

Answer 1

Kafka会自动生成一个consumer.id，用于标识消费者组中的活动消费者，但无法手动设置Kafka Consumers的consumer.id。

- Giorgos Myrianthous