升级Helidon MP 3.2.1遇Kafka异常,设置enable.idempotence=false是否可行?
问题解答
你的解决方法是正确的,具体原因和说明如下:
- Kafka客户端从2.8.x版本起,
enable.idempotence的默认值由false改为true。启用幂等性后,生产者会向Broker发送INIT_PRODUCER_ID请求,若你的Kafka Broker版本低于0.11.0.0,将不支持该请求,从而触发UnsupportedVersionException异常。 - 设置
enable.idempotence=false会禁用幂等性,此时生产者不再发送INIT_PRODUCER_ID请求,即可兼容低版本Kafka Broker。
若后续你计划将Kafka Broker升级至0.11.0.0及以上版本,建议恢复enable.idempotence的默认值(即true),以此获得生产者的Exactly-Once语义保障。
异常信息:
org.apache.kafka.common.errors.UnsupportedVersionException: The broker does not support INIT_PRODUCER_ID
内容的提问来源于stack exchange,提问作者Jan
相关产品推荐
相关产品推荐

