为什么kafka Producer有client.id?

hey*_*you 4 apache-kafka kafka-consumer-api kafka-producer-api

生产者如何使用 client.id?我的理解是,kafka消费者需要 client.id 才能将其与偏移量关联起来。例如,应用程序可以使用“abc123”client.id 从主题读取,如果失败,可以使用相同的 client.id 重新启动并从中断处继续读取。

另一方面,我的理解是制作人总是写到主题的末尾。那么,为什么 kafka 生产者需要 client.id 呢?

Mic*_*son 7

我认为你很困惑client.id并且group.id

group.id消费者使用

另一方面,client.id用于表明客户的身份。它可供所有客户端类型(生产者、消费者、管理员、连接和流)使用。它有助于识别指标或日志中的特定实例,并且还可以用于设置配额等。