You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2019/02/27 01:41:00 UTC
[jira] [Assigned] (KAFKA-7990) Flaky Test
KafkaStreamsTest#shouldCleanupOldStateDirs
[ https://issues.apache.org/jira/browse/KAFKA-7990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Guozhang Wang reassigned KAFKA-7990:
------------------------------------
Assignee: Guozhang Wang
> 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
> Assignee: Guozhang Wang
> Priority: Major
>
> [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)