Как установить consumer.id для нового потребителя Kafka
Согласно документы, Старый Consumer Configs включает consumer.id, установленный по умолчанию равным нулю:
consumer.id
Default: null
Description: Generated automatically if not set.
Можно ли установить consumer.id для Новый Kafka Consumer, и если да, то как я могу этого добиться?
@RamanMishra Также есть consumer.id.
Для чего вы это используете? Может его можно заменить на 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-.....
@GiorgosMyrianthous, ты нашел способ сделать это?
Ответы 1
Kafka автоматически генерирует consumer.id, который используется сам по себе для идентификации активных потребителей в группе потребителей, и нет можно вручную установить consumer.id для потребителей Kafka.
Я думаю, вы говорите об идентификаторе группы потребителей?