Matthias J. Sax created KAFKA-7990:
--------------------------------------
Summary: Flaky Test KafkaStreamsTest#shouldCleanupOldStateDirs
Key: KAFKA-7990
URL: https://issues.apache.org/jira/browse/KAFKA-7990
Project: Kafka
Issue Type: Bug
Components: streams, unit tests
Affects Versions: 2.2.0
Reporter: Matthias J. Sax
[https://builds.apache.org/blue/organizations/jenkins/kafka-2.0-jdk8/detail/kafka-2.0-jdk8/229/tests]
{quote}Exception in thread
"appId-78a5ef7e-0f4d-47bd-af2e-54f4606fb19e-StreamThread-189"
java.lang.IllegalArgumentException: Assigned partition input-0 for
non-subscribed topic regex pattern; subscription pattern is topic
at
org.apache.kafka.clients.consumer.internals.SubscriptionState.assignFromSubscribed(SubscriptionState.java:187)
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:244)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:422)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:352)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:337)
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:343)
at
org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1218)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1175)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1154)
at
org.apache.kafka.streams.processor.internals.StreamThread.pollRequests(StreamThread.java:861)
at
org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:810)
at
org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:767)
at
org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:736){quote}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
