Kafka Producer 重试不生效

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

这是一个创建于 1500 天前的主题，其中的信息可能已经有所发展或是发生改变。

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 条回复 • 2020-10-16 16:48:23 +08:00

sl19981007

2020-10-16 16:48:23 +08:00

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