[Bug]: Unable to connect to GMK topic using Kafka-client 4.0.0

[JayajP]

What happened?

I tried running a Dataflow job that reads messages from a Kafka topic using kafka-client 4.0.0 and my reads were silently failing. Downgrading to 3.7.0 caused reads to succeed.

When I created my Kafka Read DoFn I specify withGcpApplicationDefaultCredentials

I'm currently running beam version 2.70.0-snapshot

c.c. @johnjcasey

Issue Priority

Priority: 2 (default / most bugs should be filed as P2)

Issue Components

• Component: Python SDK
• Component: Java SDK
• Component: Go SDK
• Component: Typescript SDK
• Component: IO connector
• Component: Beam YAML
• Component: Beam examples
• Component: Beam playground
• Component: Beam katas
• Component: Website
• Component: Infrastructure
• Component: Spark Runner
• Component: Flink Runner
• Component: Samza Runner
• Component: Twister2 Runner
• Component: Hazelcast Jet Runner
• Component: Google Cloud Dataflow Runner

[an2x]

@JayajP do you have any logs / error messages / stack trace to share?

[alisha-1000]

Hi @JayajP. This might be related to Kafka 4.0 compatibility gaps in KafkaIO.

Since the failure is silent, a few things that could help move this forward:

• DEBUG-level Kafka client logs (especially auth / SASL / callback handlers)
• Whether this reproduces outside Dataflow (e.g. DirectRunner)
• Confirmation of the exact kafka-clients 4.0.0 artifact used

Given that downgrading to 3.7.0 works, it may be worth explicitly documenting (or guarding) unsupported client versions if KafkaIO isn’t fully compatible with 4.0 yet.

Happy to help investigate further once logs are available.

[aprochko]

hi @alisha-1000, colleagues

same problem there, kafka 4.0.0, 4.1.2, 4.2.0 were tested with 2.72.0 and 2.73.0. It works with 3.9.0

Whether this reproduces outside Dataflow (e.g. DirectRunner)

Also you can observe it locally.

The thing is that is just goes in circles, the job is blocked, please find the logs below

2026-05-04T13:59:31.904+02:00 DEBUG 25560 --- [ool-36-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-23, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=9, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000) to broker broker-2.<BROKER_URL>:9092 (id: 12 rack: europe-west1-c isFenced: false)
2026-05-04T13:59:31.904+02:00 DEBUG 25560 --- [ool-40-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-22, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=10, currentLeaderEpoch=22, timestamp=-1)])], timeoutMs=30000) to broker broker-0.<BROKER_URL>:9092 (id: 10 rack: europe-west1-b isFenced: false)
2026-05-04T13:59:31.904+02:00 DEBUG 25560 --- [ool-36-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-23, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-23, correlationId=76, headerVersion=2) and timeout 30000 to node 12: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=9, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:31.904+02:00 DEBUG 25560 --- [ool-40-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-22, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-22, correlationId=76, headerVersion=2) and timeout 30000 to node 10: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=10, currentLeaderEpoch=22, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:31.921+02:00 DEBUG 25560 --- [ool-38-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-24, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=11, currentLeaderEpoch=23, timestamp=-1)])], timeoutMs=30000) to broker broker-1.<BROKER_URL>:9092 (id: 11 rack: europe-west1-d isFenced: false)
2026-05-04T13:59:31.921+02:00 DEBUG 25560 --- [ool-38-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-24, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-24, correlationId=76, headerVersion=2) and timeout 30000 to node 11: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=11, currentLeaderEpoch=23, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:31.925+02:00 DEBUG 25560 --- [ool-36-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-23, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 12 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-23, correlationId=76, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=9, errorCode=0, timestamp=-1, offset=3787926, leaderEpoch=31)])])
2026-05-04T13:59:31.925+02:00 DEBUG 25560 --- [ool-40-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-22, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 10 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-22, correlationId=76, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=10, errorCode=0, timestamp=-1, offset=3149542, leaderEpoch=22)])])
2026-05-04T13:59:31.925+02:00 DEBUG 25560 --- [ool-36-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-23, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -9. Fetched offset 3787926, timestamp -1
2026-05-04T13:59:31.925+02:00 DEBUG 25560 --- [ool-40-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-22, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -10. Fetched offset 3149542, timestamp -1
2026-05-04T13:59:31.940+02:00 DEBUG 25560 --- [ool-38-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-24, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 11 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-24, correlationId=76, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=11, errorCode=0, timestamp=-1, offset=3175596, leaderEpoch=23)])])
2026-05-04T13:59:31.940+02:00 DEBUG 25560 --- [ool-38-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-24, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -11. Fetched offset 3175596, timestamp -1
2026-05-04T13:59:31.947+02:00 DEBUG 25560 --- [ool-32-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-15, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=5, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000) to broker broker-1.<BROKER_URL>:9092 (id: 11 rack: europe-west1-d isFenced: false)
2026-05-04T13:59:31.947+02:00 DEBUG 25560 --- [ool-32-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-15, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-15, correlationId=77, headerVersion=2) and timeout 30000 to node 11: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=5, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:31.967+02:00 DEBUG 25560 --- [ool-32-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-15, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 11 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-15, correlationId=77, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=5, errorCode=0, timestamp=-1, offset=3478141, leaderEpoch=31)])])
2026-05-04T13:59:31.967+02:00 DEBUG 25560 --- [ool-32-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-15, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -5. Fetched offset 3478141, timestamp -1
2026-05-04T13:59:31.968+02:00 DEBUG 25560 --- [ool-30-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-11, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=3, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000) to broker broker-2.<BROKER_URL>:9092 (id: 12 rack: europe-west1-c isFenced: false)
2026-05-04T13:59:31.968+02:00 DEBUG 25560 --- [ool-25-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-12, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=2, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000) to broker broker-1.<BROKER_URL>:9092 (id: 11 rack: europe-west1-d isFenced: false)
2026-05-04T13:59:31.968+02:00 DEBUG 25560 --- [ool-30-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-11, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-11, correlationId=77, headerVersion=2) and timeout 30000 to node 12: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=3, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:31.968+02:00 DEBUG 25560 --- [ool-25-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-12, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-12, correlationId=77, headerVersion=2) and timeout 30000 to node 11: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=2, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:31.970+02:00 DEBUG 25560 --- [ool-22-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-14, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=0, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000) to broker broker-2.<BROKER_URL>:9092 (id: 12 rack: europe-west1-c isFenced: false)
2026-05-04T13:59:31.970+02:00 DEBUG 25560 --- [ool-28-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-13, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=4, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000) to broker broker-0.<BROKER_URL>:9092 (id: 10 rack: europe-west1-b isFenced: false)
2026-05-04T13:59:31.970+02:00 DEBUG 25560 --- [ool-22-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-14, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-14, correlationId=77, headerVersion=2) and timeout 30000 to node 12: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=0, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:31.970+02:00 DEBUG 25560 --- [ool-21-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-10, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=7, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000) to broker broker-0.<BROKER_URL>:9092 (id: 10 rack: europe-west1-b isFenced: false)
2026-05-04T13:59:31.970+02:00 DEBUG 25560 --- [ool-21-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-10, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-10, correlationId=77, headerVersion=2) and timeout 30000 to node 10: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=7, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:31.970+02:00 DEBUG 25560 --- [ool-28-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-13, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-13, correlationId=77, headerVersion=2) and timeout 30000 to node 10: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=4, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:31.988+02:00 DEBUG 25560 --- [ool-25-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-12, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 11 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-12, correlationId=77, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=2, errorCode=0, timestamp=-1, offset=3450964, leaderEpoch=32)])])
2026-05-04T13:59:31.988+02:00 DEBUG 25560 --- [ool-21-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-10, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 10 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-10, correlationId=77, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=7, errorCode=0, timestamp=-1, offset=3454098, leaderEpoch=32)])])
2026-05-04T13:59:31.988+02:00 DEBUG 25560 --- [ool-28-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-13, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 10 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-13, correlationId=77, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=4, errorCode=0, timestamp=-1, offset=3435299, leaderEpoch=32)])])
2026-05-04T13:59:31.988+02:00 DEBUG 25560 --- [ool-22-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-14, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 12 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-14, correlationId=77, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=0, errorCode=0, timestamp=-1, offset=3470127, leaderEpoch=31)])])
2026-05-04T13:59:31.988+02:00 DEBUG 25560 --- [ool-30-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-11, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 12 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-11, correlationId=77, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=3, errorCode=0, timestamp=-1, offset=3513651, leaderEpoch=31)])])
2026-05-04T13:59:31.988+02:00 DEBUG 25560 --- [ool-21-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-10, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -7. Fetched offset 3454098, timestamp -1
2026-05-04T13:59:31.988+02:00 DEBUG 25560 --- [ool-25-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-12, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -2. Fetched offset 3450964, timestamp -1
2026-05-04T13:59:31.988+02:00 DEBUG 25560 --- [ool-28-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-13, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -4. Fetched offset 3435299, timestamp -1
2026-05-04T13:59:31.988+02:00 DEBUG 25560 --- [ool-30-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-11, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -3. Fetched offset 3513651, timestamp -1
2026-05-04T13:59:31.988+02:00 DEBUG 25560 --- [ool-22-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-14, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -0. Fetched offset 3470127, timestamp -1
2026-05-04T13:59:32.145+02:00 DEBUG 25560 --- [ool-24-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-16, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=6, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000) to broker broker-2.<BROKER_URL>:9092 (id: 12 rack: europe-west1-c isFenced: false)
2026-05-04T13:59:32.145+02:00 DEBUG 25560 --- [ool-24-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-16, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-16, correlationId=77, headerVersion=2) and timeout 30000 to node 12: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=6, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:32.166+02:00 DEBUG 25560 --- [ool-24-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-16, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 12 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-16, correlationId=77, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=6, errorCode=0, timestamp=-1, offset=3477747, leaderEpoch=32)])])
2026-05-04T13:59:32.166+02:00 DEBUG 25560 --- [ool-24-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-16, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -6. Fetched offset 3477747, timestamp -1
2026-05-04T13:59:32.168+02:00 DEBUG 25560 --- [ool-26-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-17, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=1, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000) to broker broker-0.<BROKER_URL>:9092 (id: 10 rack: europe-west1-b isFenced: false)
2026-05-04T13:59:32.168+02:00 DEBUG 25560 --- [ool-26-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-17, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-17, correlationId=77, headerVersion=2) and timeout 30000 to node 10: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=1, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:32.187+02:00 DEBUG 25560 --- [ool-26-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-17, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 10 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-17, correlationId=77, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=1, errorCode=0, timestamp=-1, offset=3437056, leaderEpoch=32)])])
2026-05-04T13:59:32.187+02:00 DEBUG 25560 --- [ool-26-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-17, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -1. Fetched offset 3437056, timestamp -1
2026-05-04T13:59:32.214+02:00 DEBUG 25560 --- [ool-34-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-25, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=8, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000) to broker broker-1.<BROKER_URL>:9092 (id: 11 rack: europe-west1-d isFenced: false)
2026-05-04T13:59:32.214+02:00 DEBUG 25560 --- [ool-34-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-25, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-25, correlationId=76, headerVersion=2) and timeout 30000 to node 11: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=8, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:32.233+02:00 DEBUG 25560 --- [ool-34-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-25, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 11 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-25, correlationId=76, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=8, errorCode=0, timestamp=-1, offset=3479487, leaderEpoch=31)])])
2026-05-04T13:59:32.233+02:00 DEBUG 25560 --- [ool-34-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-25, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -8. Fetched offset 3479487, timestamp -1
2026-05-04T13:59:32.904+02:00 DEBUG 25560 --- [ool-40-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-22, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=10, currentLeaderEpoch=22, timestamp=-1)])], timeoutMs=30000) to broker broker-0.<BROKER_URL>:9092 (id: 10 rack: europe-west1-b isFenced: false)
2026-05-04T13:59:32.904+02:00 DEBUG 25560 --- [ool-36-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-23, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=9, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000) to broker broker-2.<BROKER_URL>:9092 (id: 12 rack: europe-west1-c isFenced: false)
2026-05-04T13:59:32.904+02:00 DEBUG 25560 --- [ool-40-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-22, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-22, correlationId=77, headerVersion=2) and timeout 30000 to node 10: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=10, currentLeaderEpoch=22, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:32.904+02:00 DEBUG 25560 --- [ool-36-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-23, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-23, correlationId=77, headerVersion=2) and timeout 30000 to node 12: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=9, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:32.921+02:00 DEBUG 25560 --- [ool-38-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-24, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=11, currentLeaderEpoch=23, timestamp=-1)])], timeoutMs=30000) to broker broker-1.<BROKER_URL>:9092 (id: 11 rack: europe-west1-d isFenced: false)
2026-05-04T13:59:32.921+02:00 DEBUG 25560 --- [ool-38-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-24, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-24, correlationId=77, headerVersion=2) and timeout 30000 to node 11: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=11, currentLeaderEpoch=23, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:32.923+02:00 DEBUG 25560 --- [ool-40-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-22, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 10 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-22, correlationId=77, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=10, errorCode=0, timestamp=-1, offset=3149544, leaderEpoch=22)])])
2026-05-04T13:59:32.923+02:00 DEBUG 25560 --- [ool-36-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-23, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 12 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-23, correlationId=77, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=9, errorCode=0, timestamp=-1, offset=3787928, leaderEpoch=31)])])
2026-05-04T13:59:32.923+02:00 DEBUG 25560 --- [ool-40-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-22, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -10. Fetched offset 3149544, timestamp -1
2026-05-04T13:59:32.923+02:00 DEBUG 25560 --- [ool-36-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-23, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -9. Fetched offset 3787928, timestamp -1
2026-05-04T13:59:32.940+02:00 DEBUG 25560 --- [ool-38-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-24, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 11 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-24, correlationId=77, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=11, errorCode=0, timestamp=-1, offset=3175600, leaderEpoch=23)])])
2026-05-04T13:59:32.940+02:00 DEBUG 25560 --- [ool-38-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-24, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -11. Fetched offset 3175600, timestamp -1
2026-05-04T13:59:32.947+02:00 DEBUG 25560 --- [ool-32-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-15, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=5, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000) to broker broker-1.<BROKER_URL>:9092 (id: 11 rack: europe-west1-d isFenced: false)
2026-05-04T13:59:32.947+02:00 DEBUG 25560 --- [ool-32-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-15, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-15, correlationId=78, headerVersion=2) and timeout 30000 to node 11: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=5, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:32.967+02:00 DEBUG 25560 --- [ool-32-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-15, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 11 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-15, correlationId=78, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=5, errorCode=0, timestamp=-1, offset=3478141, leaderEpoch=31)])])
2026-05-04T13:59:32.967+02:00 DEBUG 25560 --- [ool-32-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-15, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -5. Fetched offset 3478141, timestamp -1
2026-05-04T13:59:32.968+02:00 DEBUG 25560 --- [ool-30-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-11, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=3, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000) to broker broker-2.<BROKER_URL>:9092 (id: 12 rack: europe-west1-c isFenced: false)
2026-05-04T13:59:32.968+02:00 DEBUG 25560 --- [ool-25-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-12, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=2, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000) to broker broker-1.<BROKER_URL>:9092 (id: 11 rack: europe-west1-d isFenced: false)
2026-05-04T13:59:32.968+02:00 DEBUG 25560 --- [ool-30-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-11, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-11, correlationId=78, headerVersion=2) and timeout 30000 to node 12: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=3, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:32.968+02:00 DEBUG 25560 --- [ool-25-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-12, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-12, correlationId=78, headerVersion=2) and timeout 30000 to node 11: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=2, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:32.969+02:00 DEBUG 25560 --- [ool-22-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-14, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=0, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000) to broker broker-2.<BROKER_URL>:9092 (id: 12 rack: europe-west1-c isFenced: false)
2026-05-04T13:59:32.969+02:00 DEBUG 25560 --- [ool-21-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-10, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=7, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000) to broker broker-0.<BROKER_URL>:9092 (id: 10 rack: europe-west1-b isFenced: false)
2026-05-04T13:59:32.969+02:00 DEBUG 25560 --- [ool-28-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-13, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=4, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000) to broker broker-0.<BROKER_URL>:9092 (id: 10 rack: europe-west1-b isFenced: false)
2026-05-04T13:59:32.969+02:00 DEBUG 25560 --- [ool-22-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-14, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-14, correlationId=78, headerVersion=2) and timeout 30000 to node 12: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=0, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:32.969+02:00 DEBUG 25560 --- [ool-21-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-10, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-10, correlationId=78, headerVersion=2) and timeout 30000 to node 10: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=7, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:32.969+02:00 DEBUG 25560 --- [ool-28-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-13, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-13, correlationId=78, headerVersion=2) and timeout 30000 to node 10: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=4, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:32.986+02:00 DEBUG 25560 --- [ool-30-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-11, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 12 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-11, correlationId=78, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=3, errorCode=0, timestamp=-1, offset=3513651, leaderEpoch=31)])])
2026-05-04T13:59:32.986+02:00 DEBUG 25560 --- [ool-21-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-10, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 10 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-10, correlationId=78, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=7, errorCode=0, timestamp=-1, offset=3454100, leaderEpoch=32)])])
2026-05-04T13:59:32.986+02:00 DEBUG 25560 --- [ool-30-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-11, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -3. Fetched offset 3513651, timestamp -1
2026-05-04T13:59:32.986+02:00 DEBUG 25560 --- [ool-25-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-12, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 11 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-12, correlationId=78, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=2, errorCode=0, timestamp=-1, offset=3450964, leaderEpoch=32)])])
2026-05-04T13:59:32.986+02:00 DEBUG 25560 --- [ool-21-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-10, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -7. Fetched offset 3454100, timestamp -1
2026-05-04T13:59:32.986+02:00 DEBUG 25560 --- [ool-22-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-14, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 12 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-14, correlationId=78, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=0, errorCode=0, timestamp=-1, offset=3470127, leaderEpoch=31)])])
2026-05-04T13:59:32.986+02:00 DEBUG 25560 --- [ool-25-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-12, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -2. Fetched offset 3450964, timestamp -1
2026-05-04T13:59:32.987+02:00 DEBUG 25560 --- [ool-22-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-14, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -0. Fetched offset 3470127, timestamp -1
2026-05-04T13:59:32.988+02:00 DEBUG 25560 --- [ool-28-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-13, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 10 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-13, correlationId=78, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=4, errorCode=0, timestamp=-1, offset=3435299, leaderEpoch=32)])])
2026-05-04T13:59:32.988+02:00 DEBUG 25560 --- [ool-28-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-13, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -4. Fetched offset 3435299, timestamp -1
2026-05-04T13:59:33.145+02:00 DEBUG 25560 --- [ool-24-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-16, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=6, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000) to broker broker-2.<BROKER_URL>:9092 (id: 12 rack: europe-west1-c isFenced: false)
2026-05-04T13:59:33.145+02:00 DEBUG 25560 --- [ool-24-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-16, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-16, correlationId=78, headerVersion=2) and timeout 30000 to node 12: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=6, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:33.166+02:00 DEBUG 25560 --- [ool-24-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-16, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 12 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-16, correlationId=78, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=6, errorCode=0, timestamp=-1, offset=3477753, leaderEpoch=32)])])
2026-05-04T13:59:33.166+02:00 DEBUG 25560 --- [ool-24-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-16, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -6. Fetched offset 3477753, timestamp -1
2026-05-04T13:59:33.169+02:00 DEBUG 25560 --- [ool-26-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-17, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=1, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000) to broker broker-0.<BROKER_URL>:9092 (id: 10 rack: europe-west1-b isFenced: false)
2026-05-04T13:59:33.169+02:00 DEBUG 25560 --- [ool-26-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-17, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-17, correlationId=78, headerVersion=2) and timeout 30000 to node 10: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=1, currentLeaderEpoch=32, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:33.188+02:00 DEBUG 25560 --- [ool-26-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-17, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 10 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-17, correlationId=78, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=1, errorCode=0, timestamp=-1, offset=3437066, leaderEpoch=32)])])
2026-05-04T13:59:33.188+02:00 DEBUG 25560 --- [ool-26-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-17, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -1. Fetched offset 3437066, timestamp -1
2026-05-04T13:59:33.213+02:00 DEBUG 25560 --- [ool-34-thread-1] o.a.k.c.c.internals.OffsetFetcher : [Consumer clientId=consumer-<GROUP_ID>-25, groupId=<GROUP_ID>] Sending ListOffsetRequest ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=8, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000) to broker broker-1.<BROKER_URL>:9092 (id: 11 rack: europe-west1-d isFenced: false)
2026-05-04T13:59:33.213+02:00 DEBUG 25560 --- [ool-34-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-25, groupId=<GROUP_ID>] Sending LIST_OFFSETS request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-25, correlationId=77, headerVersion=2) and timeout 30000 to node 11: ListOffsetsRequestData(replicaId=-1, isolationLevel=0, topics=[ListOffsetsTopic(name='', partitions=[ListOffsetsPartition(partitionIndex=8, currentLeaderEpoch=31, timestamp=-1)])], timeoutMs=30000)
2026-05-04T13:59:33.232+02:00 DEBUG 25560 --- [ool-34-thread-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-<GROUP_ID>-25, groupId=<GROUP_ID>] Received LIST_OFFSETS response from node 11 for request with header RequestHeader(apiKey=LIST_OFFSETS, apiVersion=8, clientId=consumer-<GROUP_ID>-25, correlationId=77, headerVersion=2): ListOffsetsResponseData(throttleTimeMs=0, topics=[ListOffsetsTopicResponse(name='', partitions=[ListOffsetsPartitionResponse(partitionIndex=8, errorCode=0, timestamp=-1, offset=3479492, leaderEpoch=31)])])
2026-05-04T13:59:33.232+02:00 DEBUG 25560 --- [ool-34-thread-1] o.a.k.c.c.internals.OffsetFetcherUtils : [Consumer clientId=consumer-<GROUP_ID>-25, groupId=<GROUP_ID>] Handling ListOffsetResponse response for -8. Fetched offset 3479492, timestamp -1

[aprochko]

don't know where it's best to continue, there or in #35371

@liferoad FYI