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/05 12:22:00 UTC
[jira] [Created] (KAFKA-19675) StreamsOnTasksAssignedCallbackNeededEvent could not be completed before
Lucas Brutschy created KAFKA-19675:
--------------------------------------
Summary: StreamsOnTasksAssignedCallbackNeededEvent could not be completed before
Key: KAFKA-19675
URL: https://issues.apache.org/jira/browse/KAFKA-19675
Project: Kafka
Issue Type: Sub-task
Reporter: Lucas Brutschy
In several tests, for example PlaintextAdminIntegrationTest, we see this exception silently triggered:
{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)