现象 使用这个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 的
