Gradle project
kafka-clients-0.11.0.0
And please do bare with this type of vague question. I'm not able to give the complete details due to company policies and that I won't be able to copy paste the errors as this site is not accessible in my company's virtual machine.
我是KAFKA的初学者。我被分配了一个简单的任务,让生产者在发送失败时重试。我们已经为这个send()方法添加了一个kafka producer回调,只记录响应(在引入重试之前)。
我的目标是:最多尝试5次重试。如果生产者send()方法失败,最多重试5次,如果最后一次重试也失败了,就写一个日志,说明在重试5次后发送消息的尝试失败了。
我做了如下操作。
retries = 5
我想知道以下几点。
kafka是否以任何方式记录重试的尝试?- 例如:在每次尝试时记录 "retrying...",或者在所有重试结束时记录 "失败后n次重试"。