[ create a new paste ] login | about

Link: http://codepad.org/8eHTQHWS    [ raw code | fork ]

Plain Text, pasted on Aug 10:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
[2021-08-10 11:31:38,578] DEBUG [Consumer clientId=consumer-connect-cluster-test-localhost-1, groupId=connect-cluster-test-localhost] Added READ_UNCOMMITTED fetch request for partition connect-offsets-13 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.40.0.35:9096 (id: 1002 rack: null)], epoch=0}} to node 10.40.0.35:9096 (id: 1002 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:1198)
[2021-08-10 11:31:38,578] DEBUG [Consumer clientId=consumer-connect-cluster-test-localhost-1, groupId=connect-cluster-test-localhost] Added READ_UNCOMMITTED fetch request for partition connect-offsets-1 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.40.0.35:9096 (id: 1002 rack: null)], epoch=0}} to node 10.40.0.35:9096 (id: 1002 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:1198)
[2021-08-10 11:31:38,578] DEBUG [Consumer clientId=consumer-connect-cluster-test-localhost-1, groupId=connect-cluster-test-localhost] Added READ_UNCOMMITTED fetch request for partition connect-offsets-19 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.40.0.35:9096 (id: 1002 rack: null)], epoch=0}} to node 10.40.0.35:9096 (id: 1002 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:1198)
[2021-08-10 11:31:38,578] DEBUG [Consumer clientId=consumer-connect-cluster-test-localhost-1, groupId=connect-cluster-test-localhost] Built incremental fetch (sessionId=134840849, epoch=1136) for node 1002. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 8 partition(s) (org.apache.kafka.clients.FetchSessionHandler:259)
[2021-08-10 11:31:38,578] DEBUG [Consumer clientId=consumer-connect-cluster-test-localhost-1, groupId=connect-cluster-test-localhost] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(connect-offsets-10, connect-offsets-4, connect-offsets-16, connect-offsets-22, connect-offsets-7, connect-offsets-13, connect-offsets-1, connect-offsets-19)) to broker 10.40.0.35:9096 (id: 1002 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:265)
[2021-08-10 11:31:38,578] DEBUG [Consumer clientId=consumer-connect-cluster-test-localhost-1, groupId=connect-cluster-test-localhost] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-connect-cluster-test-localhost-1, correlationId=3421) and timeout 30000 to node 1002: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=134840849, sessionEpoch=1136, topics=[], forgottenTopicsData=[], rackId='') (org.apache.kafka.clients.NetworkClient:522)
[2021-08-10 11:31:38,581] DEBUG [Consumer clientId=consumer-connect-cluster-test-localhost-2, groupId=connect-cluster-test-localhost] Received FETCH response from node 1002 for request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-connect-cluster-test-localhost-2, correlationId=3444): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=781079818, responses=[]) (org.apache.kafka.clients.NetworkClient:880)
[2021-08-10 11:31:38,582] DEBUG [Consumer clientId=consumer-connect-cluster-test-localhost-2, groupId=connect-cluster-test-localhost] Node 1002 sent an incremental fetch response with throttleTimeMs = 0 for session 781079818 with 0 response partition(s), 2 implied partition(s) (org.apache.kafka.clients.FetchSessionHandler:463)
[2021-08-10 11:31:38,582] DEBUG [Consumer clientId=consumer-connect-cluster-test-localhost-2, groupId=connect-cluster-test-localhost] Added READ_UNCOMMITTED fetch request for partition connect-status-5 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.40.0.35:9096 (id: 1002 rack: null)], epoch=0}} to node 10.40.0.35:9096 (id: 1002 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:1198)
[2021-08-10 11:31:38,582] DEBUG [Consumer clientId=consumer-connect-cluster-test-localhost-2, groupId=connect-cluster-test-localhost] Added READ_UNCOMMITTED fetch request for partition connect-status-2 at position FetchPosition{offset=28, offsetEpoch=Optional[0], currentLeader=LeaderAndEpoch{leader=Optional[10.40.0.35:9096 (id: 1002 rack: null)], epoch=0}} to node 10.40.0.35:9096 (id: 1002 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:1198)
[2021-08-10 11:31:38,582] DEBUG [Consumer clientId=consumer-connect-cluster-test-localhost-2, groupId=connect-cluster-test-localhost] Built incremental fetch (sessionId=781079818, epoch=1140) for node 1002. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 2 partition(s) (org.apache.kafka.clients.FetchSessionHandler:259)
[2021-08-10 11:31:38,582] DEBUG [Consumer clientId=consumer-connect-cluster-test-localhost-2, groupId=connect-cluster-test-localhost] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(connect-status-2, connect-status-5)) to broker 10.40.0.35:9096 (id: 1002 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:265)
[2021-08-10 11:31:38,582] DEBUG [Consumer clientId=consumer-connect-cluster-test-localhost-2, groupId=connect-cluster-test-localhost] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=consumer-connect-cluster-test-localhost-2, correlationId=3447) and timeout 30000 to node 1002: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=781079818, sessionEpoch=1140, topics=[], forgottenTopicsData=[], rackId='') (org.apache.kafka.clients.NetworkClient:522)
[2021-08-10 11:31:38,627] DEBUG [Consumer clientId=connector-consumer-elasticsearch-sink-localhost-3, groupId=connect-elasticsearch-sink-localhost] Received FETCH response from node 1002 for request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=connector-consumer-elasticsearch-sink-localhost-3, correlationId=1012): FetchResponseData(throttleTimeMs=0, errorCode=0, sessionId=1607915694, responses=[]) (org.apache.kafka.clients.NetworkClient:880)
[2021-08-10 11:31:38,627] DEBUG [Consumer clientId=connector-consumer-elasticsearch-sink-localhost-3, groupId=connect-elasticsearch-sink-localhost] Node 1002 sent an incremental fetch response with throttleTimeMs = 0 for session 1607915694 with 0 response partition(s), 1 implied partition(s) (org.apache.kafka.clients.FetchSessionHandler:463)
[2021-08-10 11:31:38,628] DEBUG [Consumer clientId=connector-consumer-elasticsearch-sink-localhost-3, groupId=connect-elasticsearch-sink-localhost] Added READ_UNCOMMITTED fetch request for partition mytopic_718-3 at position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[10.40.0.35:9096 (id: 1002 rack: null)], epoch=6}} to node 10.40.0.35:9096 (id: 1002 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:1198)
[2021-08-10 11:31:38,628] DEBUG [Consumer clientId=connector-consumer-elasticsearch-sink-localhost-3, groupId=connect-elasticsearch-sink-localhost] Built incremental fetch (sessionId=1607915694, epoch=848) for node 1002. Added 0 partition(s), altered 0 partition(s), removed 0 partition(s) out of 1 partition(s) (org.apache.kafka.clients.FetchSessionHandler:259)
[2021-08-10 11:31:38,628] DEBUG [Consumer clientId=connector-consumer-elasticsearch-sink-localhost-3, groupId=connect-elasticsearch-sink-localhost] Sending READ_UNCOMMITTED IncrementalFetchRequest(toSend=(), toForget=(), implied=(messages_718-3)) to broker 10.40.0.35:9096 (id: 1002 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher:265)
[2021-08-10 11:31:38,628] DEBUG [Consumer clientId=connector-consumer-elasticsearch-sink-localhost-3, groupId=connect-elasticsearch-sink-localhost] Sending FETCH request with header RequestHeader(apiKey=FETCH, apiVersion=12, clientId=connector-consumer-elasticsearch-sink-localhost-3, correlationId=1013) and timeout 30000 to node 1002: FetchRequestData(clusterId=null, replicaId=-1, maxWaitMs=500, minBytes=1, maxBytes=52428800, isolationLevel=0, sessionId=1607915694, sessionEpoch=848, topics=[],forgottenTopicsData=[], rackId='') (org.apache.kafka.clients.NetworkClient:522)


Create a new paste based on this one


Comments: