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)
