[jira] [Created] (KAFKA-4905) StreamPartitionAssignor doesn't respect subscriptions to asisgn partitions.

["Florian Hussonnois (JIRA)" <ji...@apache.org>]

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)