You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2025/09/10 14:51:00 UTC
[jira] [Resolved] (KAFKA-19675) StreamsOnTasksAssignedCallbackNeededEvent could not be completed
[ 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)