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