在生成或使用数据时我没有看到任何失败,但是生产中存在大量重复消息.对于获得大约100k消息的小主题,有大约4k重复,虽然我说没有失败,并且最重要的是没有实现重试逻辑或设置配置值.
我还检查了那些重复消息的偏移值,每个消息都有不同的值,告诉我问题出在生产者身上.
任何帮助将受到高度赞赏
apache-kafka kafka-consumer-api kafka-producer-api
apache-kafka ×1
kafka-consumer-api ×1
kafka-producer-api ×1