[ https://issues.apache.org/jira/browse/KAFKA-14532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
David Jacot updated KAFKA-14532: -------------------------------- Summary: Correctly handle failed fetch when partitions unassigned (was: IllegalStateException when fetch failure happens after assignment changed) > Correctly handle failed fetch when partitions unassigned > -------------------------------------------------------- > > Key: KAFKA-14532 > URL: https://issues.apache.org/jira/browse/KAFKA-14532 > Project: Kafka > Issue Type: Bug > Components: clients > Reporter: Lucas Brutschy > Assignee: Lucas Brutschy > Priority: Blocker > Fix For: 3.4.0, 3.3.2 > > > On master, all our long-running test jobs are running into this exception: > {code:java} > java.lang.IllegalStateException: No current assignment for partition > stream-soak-test-KSTREAM-OUTERTHIS-0000000086-store-changelog-1 2 at > org.apache.kafka.clients.consumer.internals.SubscriptionState.assignedState(SubscriptionState.java:370) > 3 at > org.apache.kafka.clients.consumer.internals.SubscriptionState.clearPreferredReadReplica(SubscriptionState.java:623) > 4 at java.util.LinkedHashMap$LinkedKeySet.forEach(LinkedHashMap.java:559) 5 > at > org.apache.kafka.clients.consumer.internals.Fetcher$1.onFailure(Fetcher.java:349) > 6 at > org.apache.kafka.clients.consumer.internals.RequestFuture.fireFailure(RequestFuture.java:179) > 7 at > org.apache.kafka.clients.consumer.internals.RequestFuture.raise(RequestFuture.java:149) > 8 at > org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:613) > 9 at > org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:427) > 10 at > org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:262) > 11 at > org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:251) > 12 at > org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1307) > 13 at > org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1243) > 14 at > org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1216) > 15 at > org.apache.kafka.streams.processor.internals.StoreChangelogReader.restore(StoreChangelogReader.java:450) > 16 at > org.apache.kafka.streams.processor.internals.StreamThread.initializeAndRestorePhase(StreamThread.java:910) > 17 at > org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:773) > 18 at > org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:613) > 19 at > org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:575) > 20[2022-12-13 04:01:59,024] ERROR [i-016cf5d2c1889c316-StreamThread-1] > stream-client [i-016cf5d2c1889c316] Encountered the following exception > during processing and sent shutdown request for the entire application. > (org.apache.kafka.streams.KafkaStreams) > 21org.apache.kafka.streams.errors.StreamsException: > java.lang.IllegalStateException: No current assignment for partition > stream-soak-test-KSTREAM-OUTERTHIS-0000000086-store-changelog-1 22 at > org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:653) > 23 at > org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:575) > 24Caused by: java.lang.IllegalStateException: No current assignment for > partition stream-soak-test-KSTREAM-OUTERTHIS-0000000086-store-changelog-1 25 > at > org.apache.kafka.clients.consumer.internals.SubscriptionState.assignedState(SubscriptionState.java:370) > 26 at > org.apache.kafka.clients.consumer.internals.SubscriptionState.clearPreferredReadReplica(SubscriptionState.java:623) > 27 at java.util.LinkedHashMap$LinkedKeySet.forEach(LinkedHashMap.java:559) > 28 at > org.apache.kafka.clients.consumer.internals.Fetcher$1.onFailure(Fetcher.java:349) > 29 at > org.apache.kafka.clients.consumer.internals.RequestFuture.fireFailure(RequestFuture.java:179) > 30 at > org.apache.kafka.clients.consumer.internals.RequestFuture.raise(RequestFuture.java:149) > 31 at > org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:613) > 32 at > org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:427) > 33 at > org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:262) > 34 at > org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:251) > 35 at > org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1307) > 36 at > org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1243) > 37 at > org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1216) > 38 at > org.apache.kafka.streams.processor.internals.StoreChangelogReader.restore(StoreChangelogReader.java:450) > 39 at > org.apache.kafka.streams.processor.internals.StreamThread.initializeAndRestorePhase(StreamThread.java:910) > 40 at > org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:773) > 41 at > org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:613) > 42 ... 1 more > > {code} > -- This message was sent by Atlassian Jira (v8.20.10#820010)