You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2019/02/23 18:15:00 UTC

[jira] [Created] (KAFKA-7990) Flaky Test KafkaStreamsTest#shouldCleanupOldStateDirs

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)