Kafka Producer 重试不生效

This topic created in 2066 days ago, the information mentioned may be changed or developed.

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()) 是不是和这个有关

1 replies • 2020-10-16 16:48:23 +08:00

sl19981007

Oct 16, 2020

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