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

["Fredrik Vraalsen (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16239100#comment-16239100 ] 

Fredrik Vraalsen commented on KAFKA-4905:
-----------------------------------------

[~habdank] Ah, that should have said "scale down the old streams app completely" - not the Kafka cluster of course :-)

> StreamPartitionAssignor doesn't respect subscriptions to assign 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
>            Priority: Major
>
> 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.4.14#64029)