Vahid Hashemian created KAFKA-3854: -------------------------------------- Summary: Consecutive regex subscription calls fail Key: KAFKA-3854 URL: https://issues.apache.org/jira/browse/KAFKA-3854 Project: Kafka Issue Type: Bug Components: consumer Reporter: Vahid Hashemian Assignee: Vahid Hashemian
When consecutive calls are made to new consumer's [regex subscription|https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java#L850], like below: {code} consumer.subscribe(Pattern.compile("..."), listener); consumer.poll(0); consumer.subscribe(Pattern.compile("f.."), listener); consumer.poll(0); {code} the second call fails with the following error: {code} Exception in thread "main" java.lang.IllegalStateException: Subscription to topics, partitions and pattern are mutually exclusive at org.apache.kafka.clients.consumer.internals.SubscriptionState.subscribe(SubscriptionState.java:175) at org.apache.kafka.clients.consumer.KafkaConsumer.subscribe(KafkaConsumer.java:854) at ConsumerSubscriptionSemantics.tryRegexSubscriptionSemantics(ConsumerSubscriptionSemantics.java:76) at ConsumerSubscriptionSemantics.main(ConsumerSubscriptionSemantics.java:88) {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)