2 个回答
Producer 使用幂等性的示例非常简单,与正常情况下 Producer 使用相比变化不大,只需要把 Producer 的配置 enable.idempotence 设置为 true 即可。即
props.put(“enable.idempotence”, ture)
或者props.put(ProducerConfig.ENABLE_IDEMPOTENCE_CONFIG, true)
发布于:3个月前 (02-14) IP属地:四川省
kafka producer开启幂等性直接配置enable.idempotence=true即可,例如:
props.put(ProducerConfig.ENABLE_IDEMPOTENCE_CONFIG, “true”);
发布于:3个月前 (01-24) IP属地:四川省
我来回答
您需要 登录 后回答此问题!