You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "David Jacot (Jira)" <ji...@apache.org> on 2022/12/21 08:35:00 UTC
[jira] [Updated] (KAFKA-14532) Correctly handle failed fetch when partitions unassigned
[ 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)