1
条回答
写回答
写回答
-
开发者社区问答官方账号官方回答采纳回答结果表with中加下这个参数重启后可以了properties.enable.idempotence=false 这个是高版本写入kafka的限制，阿里云Kafka不支持幂等和事务写入，在使用实时计算引擎VVR 8.0.0及以上时，需要在结果表中添加配置项properties.enable.idempotence=false以关闭幂等写入功能 https://help.aliyun.com/zh/flink/developer-reference/kafka-connector/?spm=a2c4g.11186623.0.0.74c74e4aZHIzVs#:\~:text=%E9%87%8D%E8%A6%81-,%E5%86%99%E5%85%A5%E9%98%BF%E9%87%8C%E4%BA%91Kafka%E7%9A%84%E9%99%90%E5%88%B6%EF%BC%9A,-%E9%98%BF%E9%87%8C%E4%BA%91Kafka
2024-09-29 14:11:03赞同 13 展开评论 打赏
问答分类：
关联地址：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
问答排行榜
最热
最新
推荐问答
相关文章
相关电子书
更多
