You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Marlon Ou (Jira)" <ji...@apache.org> on 2020/10/02 21:21:00 UTC

[jira] [Resolved] (KAFKA-10513) Newly added topic or partitions are not assigned to running consumer groups using static membership

     [ https://issues.apache.org/jira/browse/KAFKA-10513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Marlon Ou resolved KAFKA-10513.
-------------------------------
    Resolution: Won't Fix

> Newly added topic or partitions are not assigned to running consumer groups using static membership
> ---------------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-10513
>                 URL: https://issues.apache.org/jira/browse/KAFKA-10513
>             Project: Kafka
>          Issue Type: Bug
>          Components: consumer
>    Affects Versions: 2.6.0
>            Reporter: Marlon Ou
>            Priority: Major
>
> If consumers are polling messages from a certain topic with static membership and we add new partitions to this topic while the consumers are running, no partition reassignment is ever triggered (and hence messages published into the new partitions are never consumed). 
> To reproduce, simply set group instance IDs on the consumers: 
> {code:java}
> props.setProperty("group.instance.id", instanceId);
> {code}
> And then while the static consumers are running, use Kafka's admin client to add more partitions to the topic:
> {code:java}
> adminClient.createPartitions(...)
> {code}
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)