DEBUG main org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Completed asynchronous auto-commit of offsets {fenq-0=OffsetAndMetadata{offset=1500, leaderEpoch=0, metadata=''}, fenq-1=OffsetAndMetadata{offset=1000, leaderEpoch=0, metadata=''}}
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=679, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=523) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=681, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=523, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=681, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=524) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=682, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=524, topics=[], forgottenTopicsData=[], rackId='')
DEBUG kafka-coordinator-heartbeat-thread | few1 org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Sending Heartbeat request with generation 1 and member id consumer-few1-1-fed8e120-1764-4348-aa2d-a3c8a079a625 to coordinator 172.20.247.207:9092 (id: 2147483647 rack: null)
DEBUG kafka-coordinator-heartbeat-thread | few1 org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending HEARTBEAT request with header RequestHeader(apiKey=HEARTBEAT, apiVersion=4, clientId=consumer-few1-1, correlationId=683, headerVersion=2) and timeout 30000 to node 2147483647: HeartbeatRequestData(groupId='few1', generationId=1, memberId='consumer-few1-1-fed8e120-1764-4348-aa2d-a3c8a079a625', groupInstanceId=null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received HEARTBEAT response from node 2147483647 for request with header RequestHeader(apiKey=HEARTBEAT, apiVersion=4, clientId=consumer-few1-1, correlationId=683, headerVersion=2): HeartbeatResponseData(throttleTimeMs=0, errorCode=0)
DEBUG main org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Received successful Heartbeat response
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=682, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=525) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=684, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=525, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=684, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=526) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=685, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=526, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=685, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=527) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=686, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=527, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=686, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=528) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=687, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=528, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=687, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=529) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=688, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=529, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=688, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=530) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=689, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=530, topics=[], forgottenTopicsData=[], rackId='')
DEBUG kafka-coordinator-heartbeat-thread | few1 org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Sending Heartbeat request with generation 1 and member id consumer-few1-1-fed8e120-1764-4348-aa2d-a3c8a079a625 to coordinator 172.20.247.207:9092 (id: 2147483647 rack: null)
DEBUG kafka-coordinator-heartbeat-thread | few1 org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending HEARTBEAT request with header RequestHeader(apiKey=HEARTBEAT, apiVersion=4, clientId=consumer-few1-1, correlationId=690, headerVersion=2) and timeout 30000 to node 2147483647: HeartbeatRequestData(groupId='few1', generationId=1, memberId='consumer-few1-1-fed8e120-1764-4348-aa2d-a3c8a079a625', groupInstanceId=null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received HEARTBEAT response from node 2147483647 for request with header RequestHeader(apiKey=HEARTBEAT, apiVersion=4, clientId=consumer-few1-1, correlationId=690, headerVersion=2): HeartbeatResponseData(throttleTimeMs=0, errorCode=0)
DEBUG main org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Received successful Heartbeat response
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=689, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=531) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=691, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=531, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=691, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=532) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=692, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=532, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Sending asynchronous auto-commit of offsets {fenq-0=OffsetAndMetadata{offset=1500, leaderEpoch=0, metadata=''}, fenq-1=OffsetAndMetadata{offset=1000, leaderEpoch=0, metadata=''}}
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending OFFSET_COMMIT request with header RequestHeader(apiKey=OFFSET_COMMIT, apiVersion=8, clientId=consumer-few1-1, correlationId=693, headerVersion=2) and timeout 30000 to node 2147483647: OffsetCommitRequestData(groupId='few1', generationId=1, memberId='consumer-few1-1-fed8e120-1764-4348-aa2d-a3c8a079a625', groupInstanceId=null, retentionTimeMs=-1, topics=[OffsetCommitRequestTopic(name='fenq', partitions=[OffsetCommitRequestPartition(partitionIndex=0, committedOffset=1500, committedLeaderEpoch=0, commitTimestamp=-1, committedMetadata=''), OffsetCommitRequestPartition(partitionIndex=1, committedOffset=1000, committedLeaderEpoch=0, commitTimestamp=-1, committedMetadata='')])])
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received OFFSET_COMMIT response from node 2147483647 for request with header RequestHeader(apiKey=OFFSET_COMMIT, apiVersion=8, clientId=consumer-few1-1, correlationId=693, headerVersion=2): OffsetCommitResponseData(throttleTimeMs=0, topics=[OffsetCommitResponseTopic(name='fenq', partitions=[OffsetCommitResponsePartition(partitionIndex=0, errorCode=0), OffsetCommitResponsePartition(partitionIndex=1, errorCode=0)])])
DEBUG main org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Committed offset 1500 for partition fenq-0
DEBUG main org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Committed offset 1000 for partition fenq-1
DEBUG main org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Completed asynchronous auto-commit of offsets {fenq-0=OffsetAndMetadata{offset=1500, leaderEpoch=0, metadata=''}, fenq-1=OffsetAndMetadata{offset=1000, leaderEpoch=0, metadata=''}}
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=692, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=533) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=694, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=533, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=694, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=534) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=695, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=534, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=695, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=535) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=696, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=535, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=696, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=536) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=697, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=536, topics=[], forgottenTopicsData=[], rackId='')
DEBUG kafka-coordinator-heartbeat-thread | few1 org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Sending Heartbeat request with generation 1 and member id consumer-few1-1-fed8e120-1764-4348-aa2d-a3c8a079a625 to coordinator 172.20.247.207:9092 (id: 2147483647 rack: null)
DEBUG kafka-coordinator-heartbeat-thread | few1 org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending HEARTBEAT request with header RequestHeader(apiKey=HEARTBEAT, apiVersion=4, clientId=consumer-few1-1, correlationId=698, headerVersion=2) and timeout 30000 to node 2147483647: HeartbeatRequestData(groupId='few1', generationId=1, memberId='consumer-few1-1-fed8e120-1764-4348-aa2d-a3c8a079a625', groupInstanceId=null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received HEARTBEAT response from node 2147483647 for request with header RequestHeader(apiKey=HEARTBEAT, apiVersion=4, clientId=consumer-few1-1, correlationId=698, headerVersion=2): HeartbeatResponseData(throttleTimeMs=0, errorCode=0)
DEBUG main org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Received successful Heartbeat response
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=697, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=537) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=699, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=537, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=699, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=538) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=700, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=538, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=700, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=539) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=701, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=539, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=701, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=540) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=702, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=540, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=702, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=541) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=703, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=541, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=703, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=542) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=704, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=542, topics=[], forgottenTopicsData=[], rackId='')
DEBUG kafka-coordinator-heartbeat-thread | few1 org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Sending Heartbeat request with generation 1 and member id consumer-few1-1-fed8e120-1764-4348-aa2d-a3c8a079a625 to coordinator 172.20.247.207:9092 (id: 2147483647 rack: null)
DEBUG kafka-coordinator-heartbeat-thread | few1 org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending HEARTBEAT request with header RequestHeader(apiKey=HEARTBEAT, apiVersion=4, clientId=consumer-few1-1, correlationId=705, headerVersion=2) and timeout 30000 to node 2147483647: HeartbeatRequestData(groupId='few1', generationId=1, memberId='consumer-few1-1-fed8e120-1764-4348-aa2d-a3c8a079a625', groupInstanceId=null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received HEARTBEAT response from node 2147483647 for request with header RequestHeader(apiKey=HEARTBEAT, apiVersion=4, clientId=consumer-few1-1, correlationId=705, headerVersion=2): HeartbeatResponseData(throttleTimeMs=0, errorCode=0)
DEBUG main org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Received successful Heartbeat response
DEBUG main org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Sending asynchronous auto-commit of offsets {fenq-0=OffsetAndMetadata{offset=1500, leaderEpoch=0, metadata=''}, fenq-1=OffsetAndMetadata{offset=1000, leaderEpoch=0, metadata=''}}
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending OFFSET_COMMIT request with header RequestHeader(apiKey=OFFSET_COMMIT, apiVersion=8, clientId=consumer-few1-1, correlationId=706, headerVersion=2) and timeout 30000 to node 2147483647: OffsetCommitRequestData(groupId='few1', generationId=1, memberId='consumer-few1-1-fed8e120-1764-4348-aa2d-a3c8a079a625', groupInstanceId=null, retentionTimeMs=-1, topics=[OffsetCommitRequestTopic(name='fenq', partitions=[OffsetCommitRequestPartition(partitionIndex=0, committedOffset=1500, committedLeaderEpoch=0, commitTimestamp=-1, committedMetadata=''), OffsetCommitRequestPartition(partitionIndex=1, committedOffset=1000, committedLeaderEpoch=0, commitTimestamp=-1, committedMetadata='')])])
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received OFFSET_COMMIT response from node 2147483647 for request with header RequestHeader(apiKey=OFFSET_COMMIT, apiVersion=8, clientId=consumer-few1-1, correlationId=706, headerVersion=2): OffsetCommitResponseData(throttleTimeMs=0, topics=[OffsetCommitResponseTopic(name='fenq', partitions=[OffsetCommitResponsePartition(partitionIndex=0, errorCode=0), OffsetCommitResponsePartition(partitionIndex=1, errorCode=0)])])
DEBUG main org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Committed offset 1500 for partition fenq-0
DEBUG main org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Committed offset 1000 for partition fenq-1
DEBUG main org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Completed asynchronous auto-commit of offsets {fenq-0=OffsetAndMetadata{offset=1500, leaderEpoch=0, metadata=''}, fenq-1=OffsetAndMetadata{offset=1000, leaderEpoch=0, metadata=''}}
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=704, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=543) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=707, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=543, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=707, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=544) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=708, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=544, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=708, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=545) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=709, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=545, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=709, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=546) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=710, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=546, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending metadata request MetadataRequestData(topics=[MetadataRequestTopic(topicId=AAAAAAAAAAAAAAAAAAAAAA, name='fenq')], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending METADATA request with header RequestHeader(apiKey=METADATA, apiVersion=12, clientId=consumer-few1-1, correlationId=711, headerVersion=2) and timeout 30000 to node 0: MetadataRequestData(topics=[MetadataRequestTopic(topicId=AAAAAAAAAAAAAAAAAAAAAA, name='fenq')], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=710, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG kafka-coordinator-heartbeat-thread | few1 org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received METADATA response from node 0 for request with header RequestHeader(apiKey=METADATA, apiVersion=12, clientId=consumer-few1-1, correlationId=711, headerVersion=2): MetadataResponseData(throttleTimeMs=0, brokers=[MetadataResponseBroker(nodeId=0, host='172.20.247.207', port=9092, rack=null)], clusterId='UJdPpJCzSJ60PcYwRmRjaQ', controllerId=0, topics=[MetadataResponseTopic(errorCode=0, name='fenq', topicId=iNotEEtkQ2eIZGkAUB1y-A, isInternal=false, partitions=[MetadataResponsePartition(errorCode=0, partitionIndex=0, leaderId=0, leaderEpoch=0, replicaNodes=[0], isrNodes=[0], offlineReplicas=[]), MetadataResponsePartition(errorCode=0, partitionIndex=1, leaderId=0, leaderEpoch=0, replicaNodes=[0], isrNodes=[0], offlineReplicas=[])], topicAuthorizedOperations=-2147483648)], clusterAuthorizedOperations=-2147483648)
DEBUG kafka-coordinator-heartbeat-thread | few1 org.apache.kafka.clients.Metadata - [Consumer clientId=consumer-few1-1, groupId=few1] Updating last seen epoch for partition fenq-0 from 0 to epoch 0 from new metadata
DEBUG kafka-coordinator-heartbeat-thread | few1 org.apache.kafka.clients.Metadata - [Consumer clientId=consumer-few1-1, groupId=few1] Updating last seen epoch for partition fenq-1 from 0 to epoch 0 from new metadata
DEBUG kafka-coordinator-heartbeat-thread | few1 org.apache.kafka.clients.Metadata - [Consumer clientId=consumer-few1-1, groupId=few1] Updated cluster metadata updateVersion 3 to MetadataCache{clusterId='UJdPpJCzSJ60PcYwRmRjaQ', nodes={0=172.20.247.207:9092 (id: 0 rack: null)}, partitions=[PartitionMetadata(error=NONE, partition=fenq-0, leader=Optional[0], leaderEpoch=Optional[0], replicas=0, isr=0, offlineReplicas=), PartitionMetadata(error=NONE, partition=fenq-1, leader=Optional[0], leaderEpoch=Optional[0], replicas=0, isr=0, offlineReplicas=)], controller=172.20.247.207:9092 (id: 0 rack: null)}
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=547) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=712, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=547, topics=[], forgottenTopicsData=[], rackId='')
DEBUG kafka-coordinator-heartbeat-thread | few1 org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Sending Heartbeat request with generation 1 and member id consumer-few1-1-fed8e120-1764-4348-aa2d-a3c8a079a625 to coordinator 172.20.247.207:9092 (id: 2147483647 rack: null)
DEBUG kafka-coordinator-heartbeat-thread | few1 org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending HEARTBEAT request with header RequestHeader(apiKey=HEARTBEAT, apiVersion=4, clientId=consumer-few1-1, correlationId=713, headerVersion=2) and timeout 30000 to node 2147483647: HeartbeatRequestData(groupId='few1', generationId=1, memberId='consumer-few1-1-fed8e120-1764-4348-aa2d-a3c8a079a625', groupInstanceId=null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received HEARTBEAT response from node 2147483647 for request with header RequestHeader(apiKey=HEARTBEAT, apiVersion=4, clientId=consumer-few1-1, correlationId=713, headerVersion=2): HeartbeatResponseData(throttleTimeMs=0, errorCode=0)
DEBUG main org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Received successful Heartbeat response
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=712, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=548) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=714, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=548, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=714, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=549) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=715, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=549, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=715, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=550) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=716, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=550, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=716, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=551) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=717, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=551, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=717, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=552) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=718, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=552, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Sending asynchronous auto-commit of offsets {fenq-0=OffsetAndMetadata{offset=1500, leaderEpoch=0, metadata=''}, fenq-1=OffsetAndMetadata{offset=1000, leaderEpoch=0, metadata=''}}
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending OFFSET_COMMIT request with header RequestHeader(apiKey=OFFSET_COMMIT, apiVersion=8, clientId=consumer-few1-1, correlationId=719, headerVersion=2) and timeout 30000 to node 2147483647: OffsetCommitRequestData(groupId='few1', generationId=1, memberId='consumer-few1-1-fed8e120-1764-4348-aa2d-a3c8a079a625', groupInstanceId=null, retentionTimeMs=-1, topics=[OffsetCommitRequestTopic(name='fenq', partitions=[OffsetCommitRequestPartition(partitionIndex=0, committedOffset=1500, committedLeaderEpoch=0, commitTimestamp=-1, committedMetadata=''), OffsetCommitRequestPartition(partitionIndex=1, committedOffset=1000, committedLeaderEpoch=0, commitTimestamp=-1, committedMetadata='')])])
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received OFFSET_COMMIT response from node 2147483647 for request with header RequestHeader(apiKey=OFFSET_COMMIT, apiVersion=8, clientId=consumer-few1-1, correlationId=719, headerVersion=2): OffsetCommitResponseData(throttleTimeMs=0, topics=[OffsetCommitResponseTopic(name='fenq', partitions=[OffsetCommitResponsePartition(partitionIndex=0, errorCode=0), OffsetCommitResponsePartition(partitionIndex=1, errorCode=0)])])
DEBUG main org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Committed offset 1500 for partition fenq-0
DEBUG main org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Committed offset 1000 for partition fenq-1
DEBUG main org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Completed asynchronous auto-commit of offsets {fenq-0=OffsetAndMetadata{offset=1500, leaderEpoch=0, metadata=''}, fenq-1=OffsetAndMetadata{offset=1000, leaderEpoch=0, metadata=''}}
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=718, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=553) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=720, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=553, topics=[], forgottenTopicsData=[], rackId='')
DEBUG kafka-coordinator-heartbeat-thread | few1 org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Sending Heartbeat request with generation 1 and member id consumer-few1-1-fed8e120-1764-4348-aa2d-a3c8a079a625 to coordinator 172.20.247.207:9092 (id: 2147483647 rack: null)
DEBUG kafka-coordinator-heartbeat-thread | few1 org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending HEARTBEAT request with header RequestHeader(apiKey=HEARTBEAT, apiVersion=4, clientId=consumer-few1-1, correlationId=721, headerVersion=2) and timeout 30000 to node 2147483647: HeartbeatRequestData(groupId='few1', generationId=1, memberId='consumer-few1-1-fed8e120-1764-4348-aa2d-a3c8a079a625', groupInstanceId=null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received HEARTBEAT response from node 2147483647 for request with header RequestHeader(apiKey=HEARTBEAT, apiVersion=4, clientId=consumer-few1-1, correlationId=721, headerVersion=2): HeartbeatResponseData(throttleTimeMs=0, errorCode=0)
DEBUG main org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - [Consumer clientId=consumer-few1-1, groupId=few1] Received successful Heartbeat response
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=720, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=554) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=722, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=554, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=722, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=555) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=723, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=555, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=723, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=556) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=724, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=556, topics=[], forgottenTopicsData=[], rackId='')
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Received FETCH response from node 0 for request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=724, headerVersion=2): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=505983322, responses=[])
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Node 0 sent an incremental fetch response with throttleTimeMs = 0 for session 505983322 with 0 response partition(s), 2 implied partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-0 at position FetchPosition{offset=1500, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Added READ_UNCOMMITTED fetch request for partition fenq-1 at position FetchPosition{offset=1000, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[172.20.247.207:9092 (id: 0 rack: null)], epoch=0}} to node 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.FetchSessionHandler - [Consumer clientId=consumer-few1-1, groupId=few1] Built incremental fetch (sessionId=505983322, epoch=557) for node 0. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s), replaced 0 partition(s) out of 2 partition(s)
DEBUG main org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-few1-1, groupId=few1] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), toReplace=(), implied=(fenq-0, fenq-1), canUseTopicIds=True) to broker 172.20.247.207:9092 (id: 0 rack: null)
DEBUG main org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-few1-1, groupId=few1] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=13, clientId=consumer-few1-1, correlationId=725, headerVersion=2) and timeout 30000 to node 0: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=505983322, sessionEpoch=557, topics=[], forgottenTopicsData=[], rackId='')