flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Biao Liu <mmyy1...@gmail.com>
Subject Re: blink 版本 消费kafka 看不到group id
Date Tue, 25 Jun 2019 04:10:29 GMT
抱歉,没看懂你的问题
1. group id 和 offset 有什么关系?
2. "在kafka 里看不到group id" 指什么?

雷水鱼 <leishuiyu@daojia-inc.com> 于2019年6月24日周一 下午5:05写道:

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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message