You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 13341000780 <13...@163.com> on 2019/04/22 05:23:49 UTC

flink-kafka 消费组问题

hi, 各位大牛好！
    kafka作为数据源时，在 Properties 中设置了group.id，信息，但是同一个group下的consumer中能消费到同一个主题下想同一条消息。  另外我单独使用  kafka consumer时就不会出现这种情况，即同一个消费组下只能有一个 consume 消费到同一条消息。
    各位大牛有人遇到过这个问题吗？望赐教。


非常感谢.

Re: flink-kafka 消费组问题

Posted by Becket Qin <be...@gmail.com>.

Flink 的Kafka source没有使用 Kafka 本身的Consumer Group管理机制。所以不同Flink job 即使使用同样的
group id 也会消费到同样的消息。

On Mon, Apr 22, 2019 at 1:24 PM 13341000780 <13...@163.com> wrote:

> hi, 各位大牛好！
>     kafka作为数据源时，在 Properties 中设置了group.id，信息，但是同一个group下的consumer中能消费到同一个主题下想同一条消息。
> 另外我单独使用  kafka consumer时就不会出现这种情况，即同一个消费组下只能有一个 consume 消费到同一条消息。
>     各位大牛有人遇到过这个问题吗？望赐教。
>
>
> 非常感谢.