Hi, I used `flinkTableEnv.connect(new Kafka()...).registerTableSource(...)` to register my kafka table. However, I found that because SQL is a lazy operation, it will convert to DataStream under some criteria. For example, `Table#toRetractStream`.
So, when I used two SQLs in one application job, the same kafka table will be constructed twice. It is not a problem from flink side, because two operators held their own state for offsets. But from kafka side, they will have the same group_id. I want to make sure that only one kafka source will commit group_id's offsets back to kafka. A workaround might be registering the same kafka topic twice with different name, group_id for two SQLs. But I would still like to know if there is any way to make two SQLs just read from the same KafkaTableSource? Thanks in advance. Best, Tony Wei
