[jira] [Created] (FLINK-11435) Different jobs same consumer group are treated as separate groups

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-11435) Different jobs same consumer group are treated as separate groups

Shang Yuanchun (Jira)
Avi Levi created FLINK-11435:
--------------------------------

             Summary: Different jobs same consumer group are treated as separate groups
                 Key: FLINK-11435
                 URL: https://issues.apache.org/jira/browse/FLINK-11435
             Project: Flink
          Issue Type: Bug
          Components: Kafka Connector
    Affects Versions: 1.7.1
         Environment: kafka consumer
            Reporter: Avi Levi


deploying two jobs with the same consumer group id, still treated as different consumer groups. This behavior does not comply with kafka expectations. Same consumer group ids should be treated as the same group this will enable deploying more jobs (specially if they are stateless ) on demand and it also how normal consumer groups behave. 

reproduce :

deploy the same job twice - both jobs consumes the same message although they share the same consumer id



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)