现象 
使用这个pom ,在kafka 里看不到group id 
<dependency>
 <groupId>com.alibaba.blink</groupId>
 <artifactId>flink-streaming-scala_2.11</artifactId>
 <version>blink-3.2.2</version>
 <exclusions>
 <exclusion>
 <groupId>org.slf4j</groupId>
 <artifactId>slf4j-api</artifactId>
 </exclusion>
 </exclusions>
</dependency>
<dependency>
 <groupId>com.alibaba.blink</groupId>
 <artifactId>flink-connector-kafka-0.11_2.11</artifactId>
 <version>blink-3.2.0</version>
 <exclusions>
 <exclusion>
 <groupId>org.slf4j</groupId>
 <artifactId>slf4j-api</artifactId>
 </exclusion>
 </exclusions>
</dependency>
使用开源版本,可以看到在kafka 看到group id 
<dependency>
 <groupId>org.apache.flink</groupId>
 <artifactId>flink-streaming-java_2.12</artifactId>
 <version>1.7.1</version>
</dependency>

<!-- 
https://mvnrepository.com/artifact/org.apache.flink/flink-connector-kafka-0.11 
-->
<dependency>
 <groupId>org.apache.flink</groupId>
 <artifactId>flink-connector-kafka-0.11_2.12</artifactId>
 <version>1.7.1</version>
</dependency>

有没有大佬能看一下,在业务场景 中 还是需要看下 offset 的



回复