flink1.11 kafka sql connector

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

flink1.11 kafka sql connector

Dream-底限
hi
我正在使用DDL语句创建kafka数据源,但是查看文档时候发现没有报漏参数指定消费者组的offset是否提交,请问这个默认情况下offset会不会提交到kafka分区
Reply | Threaded
Open this post in threaded view
|

RE: flink1.11 kafka sql connector

venn
默认应该是 Kafka 的自动提交,开了Checkpoint 就 Checkpoint 提交

-----Original Message-----
From: user-zh-return-6960-wxchunjhyy=[hidden email] <user-zh-return-6960-wxchunjhyy=[hidden email]> On Behalf Of Dream-底限
Sent: Wednesday, August 26, 2020 10:42 AM
To: [hidden email]
Subject: flink1.11 kafka sql connector

hi
我正在使用DDL语句创建kafka数据源,但是查看文档时候发现没有报漏参数指定消费者组的offset是否提交,请问这个默认情况下offset会不会提交到kafka分区