Kafka Producer应该重试3次，以防失败

Question

我想在出现任何故障的情况下执行卡夫卡生产者重试逻辑三遍，而且我想手动测试生产者是否在重试。您能建议我如何手动测试此功能。在下面的配置中，添加到生产者配置以在发生任何故障时重试。谢谢。

props.put("retries", 3);

Answer 1

您应该信任Kafka的这一核心功能，但是可以通过捕获生产者的数据包来跟踪它。

您可以使用tcpdump来排序生产者服务器上的数据包并检查它们发送了多少时间：tcpdump -i any port 9092我也建议您查看有关使用tshark捕获Kafka的answer。

如果您想更深入地研究协议，可以使用WireShark。查阅有关how to install WireShark on Linux的指南。