Florian Hussonnois created KAFKA-4905:
-----------------------------------------
Summary: StreamPartitionAssignor doesn't respect subscriptions to
asisgn partitions.
Key: KAFKA-4905
URL: https://issues.apache.org/jira/browse/KAFKA-4905
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 0.10.2.0
Reporter: Florian Hussonnois
Both RangeAssignor and RoundRobinAssignor use the subscriptions to assign
partition to each consumer. This allow to have two consumers belonging to the
the same group and subscribing to two differents topics.
This doesn't seem to be the case of the StreamPartitionAssignor resulting to an
IllegalArgumentException thrown during rebalance.
java.lang.IllegalArgumentException: Assigned partition foo-2 for non-subscribed
topic regex pattern; subscription pattern is bar
at
org.apache.kafka.clients.consumer.internals.SubscriptionState.assignFromSubscribed(SubscriptionState.java:190)
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:216)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:352)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:303)
This is because the consumer group leader attempt to assign partitions to a
consumer that didn't subscribe to the associated topic.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
