疑问：flink sql 当一个env下多个insert语句共享一个view时，是否会影响view中kafka源表的offset提交

Thu, 28 May 2020 00:15:09 -0700 

Hi,all:
当前使用版本flink 1.10.0，使用blink planner，假如有如下代码：

tEnv.createTemporaryView("b", tEnv.sqlQuery("select * from a"));
tEnv.sqlUpdate("insert into c select * from b where b.con1 = '1'");
tEnv.sqlUpdate("insert into d select * from b where b.con1 = '2'");

其中a是kafka表，connector属性为：
'connector.properties.group.id' = 'testGroup',
'connector.startup-mode' = 'group-offsets'

           疑问是该应用运行时c、d消费a表，a表group 'testGroup' 
offset的提交会不会受到影响，还是a表中同一条记录会流向2个不同的分支？

回复