Kafka Producer应重试三次，以防失败

Question

我想在任何失败的情况下实现三次Kafka生产者重试逻辑，还想手动测试生产者是否正在重试。你能建议我如何手动测试这个功能吗。在下面的配置中，将添加到生产者配置中，以便在出现任何故障时重试。非常感谢。

props.put("retries", 3);

Answer 1

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

您可以使用tcpdump在生产者服务器上嗅探数据包，并检查它们发送了多少次：
tcpdump -i any port 9092
我还建议您查看关于使用tshark捕获Kafka的答案。

如果你想更深入地研究协议，你可以使用WireShark
查看本指南，了解如何在Linux上安装WireShark。