Marlon Ou created KAFKA-10513:
---------------------------------
Summary: Newly added partitions are not assigned to running static
consumer
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
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)
