Kafka Producer 重试不生效

[sl19981007]

retries 设置了为 3 但是没有生效 Producer 配置如下

props.put("bootstrap.servers", Config.feedback_log_kafka_server)
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer")
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer")
props.put("request.timeout.ms", "60000")
props.put("acks", "1")
props.put("retries", "3")

producer send 的时候传入了自己的 callback 函数 producer.send(record, new ProducerCallBack()) 是不是和这个有关

[sl19981007]

有木有大佬回复一下小弟 wuwuwu