当acks=all时,是否可以记录或处理自动Kafka生产者重试

ej83mcc0  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(195)

我知道我可以 acks=all 在kafka producer配置中,使producer在所有副本接收到发送的消息后等待leader的确认。如果发生确认超时,生产者将重试发送消息。这是透明的,不需要任何代码更改。有没有可能有一些重试的数据。是否有可能知道哪些消息涉及重试以及重试次数。kafka是否提供了在重试之前/之后调用的任何类型的钩子,以便我们可以记录一些消息?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题