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

Chia-Ping Tsai updated KAFKA-21409:
-----------------------------------
    Affects Version/s: 4.3.2
                       4.2.2
                       4.4.0
                       4.3.1
                       4.2.1
                       4.1.2
                       4.1.1
                       4.0.2
                       4.3.0
                       4.2.0
                       4.1.0
                       4.0.1
                       4.0.0

> Switching to a subscription regex that matches no topic doesn't trigger 
> rebalance
> ---------------------------------------------------------------------------------
>
>                 Key: KAFKA-21409
>                 URL: https://issues.apache.org/jira/browse/KAFKA-21409
>             Project: Kafka
>          Issue Type: Bug
>    Affects Versions: 4.0.0, 4.0.1, 4.1.0, 4.2.0, 4.3.0, 4.0.2, 4.1.1, 4.1.2, 
> 4.2.1, 4.3.1, 4.4.0, 4.2.2, 4.3.2
>            Reporter: Chia-Ping Tsai
>            Assignee: Chia-Ping Tsai
>            Priority: Major
>
>  
> {code:java}
> ResolvedRegularExpression newResolvedRegularExpression = entry.getValue();
> ResolvedRegularExpression oldResolvedRegularExpression = group
>   .resolvedRegularExpression(regex)
>   .orElse(ResolvedRegularExpression.EMPTY);                
> if 
> (!oldResolvedRegularExpression.topics().equals(newResolvedRegularExpression.topics()))
>  {
> {code}
> Since ResolvedRegularExpression.EMPTY has no topics which is equal to 
> "match-to-nothing", the condition won't get passed. The side effect is that 
> the partitions won't be reassigned to other consumers.
>  



--
This message was sent by Atlassian Jira
(v10.3.26#10030026)

Reply via email to