[
https://issues.apache.org/jira/browse/KAFKA-19675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy updated KAFKA-19675:
-----------------------------------
Description:
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}
was:
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}
> StreamsOnTasksAssignedCallbackNeededEvent could not be completed
> ------------------------------------------------------------------
>
> Key: KAFKA-19675
> URL: https://issues.apache.org/jira/browse/KAFKA-19675
> Project: Kafka
> Issue Type: Sub-task
> 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)
