aprochko commented on issue #36710: URL: https://github.com/apache/beam/issues/36710#issuecomment-4370879850
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 >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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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 <TOPIC>-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 <TOPIC>-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='<TOPIC>', 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 <TOPIC>-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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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 <TOPIC>-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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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 <TOPIC>-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 <TOPIC>-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 <TOPIC>-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 <TOPIC>-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 <TOPIC>-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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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 <TOPIC>-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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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 <TOPIC>-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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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 <TOPIC>-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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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 <TOPIC>-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 <TOPIC>-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='<TOPIC>', 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 <TOPIC>-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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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 <TOPIC>-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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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 <TOPIC>-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='<TOPIC>', 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 <TOPIC>-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='<TOPIC>', 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 <TOPIC>-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 <TOPIC>-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='<TOPIC>', 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 <TOPIC>-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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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 <TOPIC>-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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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 <TOPIC>-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='<TOPIC>', 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='<TOPIC>', 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='<TOPIC>', 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 <TOPIC>-8. Fetched offset 3479492, timestamp -1 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
