[
https://issues.apache.org/jira/browse/KAFKA-19675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy resolved KAFKA-19675.
------------------------------------
Resolution: Won't Fix
> StreamsOnTasksAssignedCallbackNeededEvent could not be completed
> ------------------------------------------------------------------
>
> Key: KAFKA-19675
> URL: https://issues.apache.org/jira/browse/KAFKA-19675
> Project: Kafka
> Issue Type: Sub-task
> Components: streams
> Reporter: Lucas Brutschy
> Priority: Major
>
> In several tests, for example PlaintextAdminIntegrationTest, we see this
> exception silently triggered when the consumer is closed.
>
> {code:java}
> org.apache.kafka.common.errors.TimeoutException:
> StreamsOnTasksAssignedCallbackNeededEvent could not be completed before the
> consumer closed[2025-09-05 14:17:40,972] ERROR [Consumer
> clientId=consumer-stream_group_id_1-1, groupId=stream_group_id_1]
> Reconciliation failed: callback invocation failed for tasks
> LocalAssignment{localEpoch=0, activeTasks={subtopology-0=[0, 1, 2]},
> standbyTasks={}, warmupTasks={}}
> (org.apache.kafka.clients.consumer.internals.StreamsMembershipManager:1077)java.util.concurrent.CompletionException:
> org.apache.kafka.common.errors.TimeoutException:
> StreamsOnTasksAssignedCallbackNeededEvent could not be completed before the
> consumer closed at
> java.base/java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:368)
> at
> java.base/java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:377)
> at
> java.base/java.util.concurrent.CompletableFuture$UniRelay.tryFire(CompletableFuture.java:1097)
> at
> java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
> at
> java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2162)
> at
> org.apache.kafka.clients.consumer.internals.events.CompletableEventReaper.completeEventsExceptionallyOnClose(CompletableEventReaper.java:202)
> at
> org.apache.kafka.clients.consumer.internals.events.CompletableEventReaper.reap(CompletableEventReaper.java:149)
> at
> org.apache.kafka.clients.consumer.internals.AsyncKafkaConsumer.close(AsyncKafkaConsumer.java:1493)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
