pchang388 commented on issue #12701:
URL: https://github.com/apache/druid/issues/12701#issuecomment-1179363544
> Hey @pchang388, is it possible that the state hasn't transitioned from
STARTING to READING? Do you see INFO logs like: "Seeking partition['partition
id'] to['sequence']." ?
Hey @AmatyaAvadhanula - thanks for taking a look! I do see one log entry
with that info level message and also a few similar ones. That specific log
message appears once early in the task lifecycle during the starting phase
(Task start time: 2022-07-06T20:56:26.370Z). Here are the logs around that time
frame including the specific message
```
2022-07-06T20:56:30,726 INFO [task-runner-0-priority-0]
org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner -
Seeking partition[1] to[28356503735].
2022-07-06T20:56:30,726 INFO [task-runner-0-priority-0]
org.apache.kafka.clients.consumer.KafkaConsumer - [Consumer
clientId=consumer-kafka-supervisor-jlnikjkf-1,
groupId=kafka-supervisor-jlnikjkf] Seeking to offset 28356503735 for partition
REDACT-1
...
2022-07-06T20:56:30,728 DEBUG [task-runner-0-priority-0]
org.apache.kafka.clients.NetworkClient - [Consumer
clientId=consumer-kafka-supervisor-jlnikjkf-1,
groupId=kafka-supervisor-jlnikjkf] Initialize connection to node
KAFKA_BROKER:9094 (id: -1 rack: null) for sending metadata request
2022-07-06T20:56:30,729 DEBUG [task-runner-0-priority-0]
org.apache.kafka.clients.NetworkClient - [Consumer
clientId=consumer-kafka-supervisor-jlnikjkf-1,
groupId=kafka-supervisor-jlnikjkf] Initiating connection to node
KAFKA_BROKER:9094 (id: -1 rack: null) using address /KAFKA_BROKER
2022-07-06T20:56:30,736 DEBUG [task-runner-0-priority-0]
org.apache.kafka.common.network.Selector - [Consumer
clientId=consumer-kafka-supervisor-jlnikjkf-1,
groupId=kafka-supervisor-jlnikjkf] Created socket with SO_RCVBUF = 65536,
SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1
...
2022-07-06T20:56:30,951 DEBUG [task-runner-0-priority-0]
org.apache.kafka.clients.NetworkClient - [Consumer
clientId=consumer-kafka-supervisor-jlnikjkf-1,
groupId=kafka-supervisor-jlnikjkf] Completed connection to node -1. Fetching
API versions.
2022-07-06T20:56:30,951 DEBUG [task-runner-0-priority-0]
org.apache.kafka.clients.NetworkClient - [Consumer
clientId=consumer-kafka-supervisor-jlnikjkf-1,
groupId=kafka-supervisor-jlnikjkf] Initiating API versions fetch from node -1.
2022-07-06T20:56:30,977 DEBUG [task-runner-0-priority-0]
org.apache.kafka.clients.NetworkClient - [Consumer
clientId=consumer-kafka-supervisor-jlnikjkf-1,
groupId=kafka-supervisor-jlnikjkf] Sending API_VERSIONS request with header
RequestHeader(apiKey=API_VERSIONS, apiVersion=3,
clientId=consumer-kafka-supervisor-jlnikjkf-1, correlationId=0) and timeout
60000 to node -1:
ApiVersionsRequestData(clientSoftwareName='apache-kafka-java',
clientSoftwareVersion='2.8.0')
2022-07-06T20:56:30,989 DEBUG [task-runner-0-priority-0]
org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer
clientId=consumer-kafka-supervisor-jlnikjkf-1,
groupId=kafka-supervisor-jlnikjkf] Requesting metadata update for partition
REDACT-1 since the position FetchPosition{offset=28356503735,
offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional.empty,
epoch=absent}} is missing the current leader node
2022-07-06T20:56:31,024 DEBUG [task-runner-0-priority-0]
org.apache.kafka.clients.NetworkClient - [Consumer
clientId=consumer-kafka-supervisor-jlnikjkf-1,
groupId=kafka-supervisor-jlnikjkf] Received API_VERSIONS response from node -1
for request with header RequestHeader(apiKey=API_VERSIONS, apiVersion=3,
clientId=consumer-kafka-supervisor-jlnikjkf-1, correlationId=0):
ApiVersionsResponseData(errorCode=0, apiKeys=[ApiVersion(apiKey=0,
minVersion=0, maxVersion=9), ApiVersion(apiKey=1, minVersion=0, maxVersion=12),
ApiVersion(apiKey=2, minVersion=0, maxVersion=6), ApiVersion(apiKey=3,
minVersion=0, maxVersion=11), ApiVersion(apiKey=4, minVersion=0, maxVersion=5),
ApiVersion(apiKey=5, minVersion=0, maxVersion=3), ApiVersion(apiKey=6,
minVersion=0, maxVersion=7), ApiVersion(apiKey=7, minVersion=0, maxVersion=3),
ApiVersion(apiKey=8, minVersion=0, maxVersion=8), ApiVersion(apiKey=9,
minVersion=0, maxVersion=7), ApiVersion(apiKey=10, minVersion=0, maxVersion=3),
ApiVersion(apiKey=11, mi
nVersion=0, maxVersion=7), ApiVersion(apiKey=12, minVersion=0, maxVersion=4),
ApiVersion(apiKey=13, minVersion=0, maxVersion=4), ApiVersion(apiKey=14,
minVersion=0, maxVersion=5), ApiVersion(apiKey=15, minVersion=0, maxVersion=5),
ApiVersion(apiKey=16, minVersion=0, maxVersion=4), ApiVersion(apiKey=17,
minVersion=0, maxVersion=1), ApiVersion(apiKey=18, minVersion=0, maxVersion=3),
ApiVersion(apiKey=19, minVersion=0, maxVersion=7), ApiVersion(apiKey=20,
minVersion=0, maxVersion=6), ApiVersion(apiKey=21, minVersion=0, maxVersion=2),
ApiVersion(apiKey=22, minVersion=0, maxVersion=4), ApiVersion(apiKey=23,
minVersion=0, maxVersion=4), ApiVersion(apiKey=24, minVersion=0, maxVersion=3),
ApiVersion(apiKey=25, minVersion=0, maxVersion=3), ApiVersion(apiKey=26,
minVersion=0, maxVersion=3), ApiVersion(apiKey=27, minVersion=0, maxVersion=1),
ApiVersion(apiKey=28, minVersion=0, maxVersion=3), ApiVersion(apiKey=29,
minVersion=0, maxVersion=2), ApiVersion(apiKey=30, minVersion=0, maxVersion=2),
A
piVersion(apiKey=31, minVersion=0, maxVersion=2), ApiVersion(apiKey=32,
minVersion=0, maxVersion=4), ApiVersion(apiKey=33, minVersion=0, maxVersion=2),
ApiVersion(apiKey=34, minVersion=0, maxVersion=2), ApiVersion(apiKey=35,
minVersion=0, maxVersion=2), ApiVersion(apiKey=36, minVersion=0, maxVersion=2),
ApiVersion(apiKey=37, minVersion=0, maxVersion=3), ApiVersion(apiKey=38,
minVersion=0, maxVersion=2), ApiVersion(apiKey=39, minVersion=0, maxVersion=2),
ApiVersion(apiKey=40, minVersion=0, maxVersion=2), ApiVersion(apiKey=41,
minVersion=0, maxVersion=2), ApiVersion(apiKey=42, minVersion=0, maxVersion=2),
ApiVersion(apiKey=43, minVersion=0, maxVersion=2), ApiVersion(apiKey=44,
minVersion=0, maxVersion=1), ApiVersion(apiKey=45, minVersion=0, maxVersion=0),
ApiVersion(apiKey=46, minVersion=0, maxVersion=0), ApiVersion(apiKey=47,
minVersion=0, maxVersion=0), ApiVersion(apiKey=48, minVersion=0, maxVersion=1),
ApiVersion(apiKey=49, minVersion=0, maxVersion=1), ApiVersion(apiKey=50, minVers
ion=0, maxVersion=0), ApiVersion(apiKey=51, minVersion=0, maxVersion=0),
ApiVersion(apiKey=56, minVersion=0, maxVersion=0), ApiVersion(apiKey=57,
minVersion=0, maxVersion=0), ApiVersion(apiKey=60, minVersion=0, maxVersion=0),
ApiVersion(apiKey=61, minVersion=0, maxVersion=0)], throttleTimeMs=0,
supportedFeatures=[], finalizedFeaturesEpoch=0, finalizedFeatures=[])
...
2022-07-06T20:56:31,075 DEBUG [task-runner-0-priority-0]
org.apache.kafka.clients.NetworkClient - [Consumer
clientId=consumer-kafka-supervisor-jlnikjkf-1,
groupId=kafka-supervisor-jlnikjkf] Node -1 has finalized features epoch: 0,
finalized features: [], supported features: [], API versions: (Produce(0): 0 to
9 [usable: 9], Fetch(1): 0 to 12 [usable: 12], ListOffsets(2): 0 to 6 [usable:
6], Metadata(3): 0 to 11 [usable: 11], LeaderAndIsr(4): 0 to 5 [usable: 5],
StopReplica(5): 0 to 3 [usable: 3], UpdateMetadata(6): 0 to 7 [usable: 7],
ControlledShutdown(7): 0 to 3 [usable: 3], OffsetCommit(8): 0 to 8 [usable: 8],
OffsetFetch(9): 0 to 7 [usable: 7], FindCoordinator(10): 0 to 3 [usable: 3],
JoinGroup(11): 0 to 7 [usable: 7], Heartbeat(12): 0 to 4 [usable: 4],
LeaveGroup(13): 0 to 4 [usable: 4], SyncGroup(14): 0 to 5 [usable: 5],
DescribeGroups(15): 0 to 5 [usable: 5], ListGroups(16): 0 to 4 [usable: 4],
SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 3 [usable: 3], Crea
teTopics(19): 0 to 7 [usable: 7], DeleteTopics(20): 0 to 6 [usable: 6],
DeleteRecords(21): 0 to 2 [usable: 2], InitProducerId(22): 0 to 4 [usable: 4],
OffsetForLeaderEpoch(23): 0 to 4 [usable: 4], AddPartitionsToTxn(24): 0 to 3
[usable: 3], AddOffsetsToTxn(25): 0 to 3 [usable: 3], EndTxn(26): 0 to 3
[usable: 3], WriteTxnMarkers(27): 0 to 1 [usable: 1], TxnOffsetCommit(28): 0 to
3 [usable: 3], DescribeAcls(29): 0 to 2 [usable: 2], CreateAcls(30): 0 to 2
[usable: 2], DeleteAcls(31): 0 to 2 [usable: 2], DescribeConfigs(32): 0 to 4
[usable: 4], AlterConfigs(33): 0 to 2 [usable: 2], AlterReplicaLogDirs(34): 0
to 2 [usable: 2], DescribeLogDirs(35): 0 to 2 [usable: 2],
SaslAuthenticate(36): 0 to 2 [usable: 2], CreatePartitions(37): 0 to 3 [usable:
3], CreateDelegationToken(38): 0 to 2 [usable: 2], RenewDelegationToken(39): 0
to 2 [usable: 2], ExpireDelegationToken(40): 0 to 2 [usable: 2],
DescribeDelegationToken(41): 0 to 2 [usable: 2], DeleteGroups(42): 0 to 2
[usable: 2], ElectLeaders(43
): 0 to 2 [usable: 2], IncrementalAlterConfigs(44): 0 to 1 [usable: 1],
AlterPartitionReassignments(45): 0 [usable: 0], ListPartitionReassignments(46):
0 [usable: 0], OffsetDelete(47): 0 [usable: 0], DescribeClientQuotas(48): 0 to
1 [usable: 1], AlterClientQuotas(49): 0 to 1 [usable: 1],
DescribeUserScramCredentials(50): 0 [usable: 0], AlterUserScramCredentials(51):
0 [usable: 0], AlterIsr(56): 0 [usable: 0], UpdateFeatures(57): 0 [usable: 0],
DescribeCluster(60): 0 [usable: 0], DescribeProducers(61): 0 [usable: 0]).
...
2022-07-06T20:56:31,077 DEBUG [task-runner-0-priority-0]
org.apache.kafka.clients.NetworkClient - [Consumer
clientId=consumer-kafka-supervisor-jlnikjkf-1,
groupId=kafka-supervisor-jlnikjkf] Sending metadata request
MetadataRequestData(topics=[MetadataRequestTopic(topicId=AAAAAAAAAAAAAAAAAAAAAA,
name='REDACT')], allowAutoTopicCreation=true,
includeClusterAuthorizedOperations=false,
includeTopicAuthorizedOperations=false) to node KAFKA_BROKER:9094 (id: -1 rack:
null)
2022-07-06T20:56:31,077 DEBUG [task-runner-0-priority-0]
org.apache.kafka.clients.NetworkClient - [Consumer
clientId=consumer-kafka-supervisor-jlnikjkf-1,
groupId=kafka-supervisor-jlnikjkf] Sending METADATA request with header
RequestHeader(apiKey=METADATA, apiVersion=11,
clientId=consumer-kafka-supervisor-jlnikjkf-1, correlationId=1) and timeout
60000 to node -1:
MetadataRequestData(topics=[MetadataRequestTopic(topicId=AAAAAAAAAAAAAAAAAAAAAA,
name='REDACT')], allowAutoTopicCreation=true,
includeClusterAuthorizedOperations=false,
includeTopicAuthorizedOperations=false)
2022-07-06T20:56:31,081 DEBUG [task-runner-0-priority-0]
org.apache.kafka.clients.NetworkClient - [Consumer
clientId=consumer-kafka-supervisor-jlnikjkf-1,
groupId=kafka-supervisor-jlnikjkf] Received METADATA response from node -1 for
request with header RequestHeader(apiKey=METADATA, apiVersion=11,
clientId=consumer-kafka-supervisor-jlnikjkf-1, correlationId=1):
MetadataResponseData(throttleTimeMs=0,
brokers=[MetadataResponseBroker(nodeId=2, host='KAFKA_BROKER2', port=9094,
rack=null), MetadataResponseBroker(nodeId=3, host='KAFKA_BROKER3', port=9094,
rack=null), MetadataResponseBroker(nodeId=1, host='KAFKA_BROKER', port=9094,
rack=null)], clusterId='-Q04QWMvT1qkE0AOEv9bPQ', controllerId=2,
topics=[MetadataResponseTopic(errorCode=0, name='REDACT',
topicId=CViGKrvaQI6m23zzIH6Dug, isInternal=false,
partitions=[MetadataResponsePartition(errorCode=0, partitionIndex=0,
leaderId=2, leaderEpoch=56, replicaNodes=[2, 1, 3], isrNodes=[2, 1, 3],
offlineReplicas=[]), MetadataResponsePartition(
errorCode=0, partitionIndex=5, leaderId=1, leaderEpoch=62, replicaNodes=[1, 2,
3], isrNodes=[2, 1, 3], offlineReplicas=[]),
MetadataResponsePartition(errorCode=0, partitionIndex=4, leaderId=3,
leaderEpoch=65, replicaNodes=[3, 1, 2], isrNodes=[2, 1, 3],
offlineReplicas=[]), MetadataResponsePartition(errorCode=0, partitionIndex=1,
leaderId=3, leaderEpoch=65, replicaNodes=[3, 2, 1], isrNodes=[2, 1, 3],
offlineReplicas=[]), MetadataResponsePartition(errorCode=0, partitionIndex=2,
leaderId=1, leaderEpoch=62, replicaNodes=[1, 3, 2], isrNodes=[2, 1, 3],
offlineReplicas=[]), MetadataResponsePartition(errorCode=0, partitionIndex=3,
leaderId=2, leaderEpoch=57, replicaNodes=[2, 3, 1], isrNodes=[2, 1, 3],
offlineReplicas=[])], topicAuthorizedOperations=-2147483648)],
clusterAuthorizedOperations=-2147483648)
2022-07-06T20:56:31,084 DEBUG [task-runner-0-priority-0]
org.apache.kafka.clients.Metadata - [Consumer
clientId=consumer-kafka-supervisor-jlnikjkf-1,
groupId=kafka-supervisor-jlnikjkf] Updating last seen epoch for partition
REDACT-0 from null to epoch 56 from new metadata
2022-07-06T20:56:31,085 DEBUG [task-runner-0-priority-0]
org.apache.kafka.clients.Metadata - [Consumer
clientId=consumer-kafka-supervisor-jlnikjkf-1,
groupId=kafka-supervisor-jlnikjkf] Updating last seen epoch for partition
REDACT-5 from null to epoch 62 from new metadata
2022-07-06T20:56:31,085 DEBUG [task-runner-0-priority-0]
org.apache.kafka.clients.Metadata - [Consumer
clientId=consumer-kafka-supervisor-jlnikjkf-1,
groupId=kafka-supervisor-jlnikjkf] Updating last seen epoch for partition
REDACT-4 from null to epoch 65 from new metadata
2022-07-06T20:56:31,085 DEBUG [task-runner-0-priority-0]
org.apache.kafka.clients.Metadata - [Consumer
clientId=consumer-kafka-supervisor-jlnikjkf-1,
groupId=kafka-supervisor-jlnikjkf] Updating last seen epoch for partition
REDACT-1 from null to epoch 65 from new metadata
2022-07-06T20:56:31,085 DEBUG [task-runner-0-priority-0]
org.apache.kafka.clients.Metadata - [Consumer
clientId=consumer-kafka-supervisor-jlnikjkf-1,
groupId=kafka-supervisor-jlnikjkf] Updating last seen epoch for partition
REDACT-2 from null to epoch 62 from new metadata
2022-07-06T20:56:31,085 DEBUG [task-runner-0-priority-0]
org.apache.kafka.clients.Metadata - [Consumer
clientId=consumer-kafka-supervisor-jlnikjkf-1,
groupId=kafka-supervisor-jlnikjkf] Updating last seen epoch for partition
REDACT-3 from null to epoch 57 from new metadata
```
Before and After the "pause" that never appeared to paused and showed the
debug message, I also see it producing metrics for kafka metrics emitter: -
probably not as relevant but showing it can communicate with kafka brokers
before and after:
```
2022-07-06T21:56:34,580 DEBUG [kafka-producer-network-thread | producer-1]
org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1]
Received PRODUCE response from node 1 for request with header
RequestHeader(apiKey=PRODUCE, apiVersion=9, clientId=producer-1,
correlationId=1554):
ProduceResponseData(responses=[TopicProduceResponse(name='druid_metrics',
partitionResponses=[PartitionProduceResponse(index=4, errorCode=0,
baseOffset=25318043000, logAppendTimeMs=-1, logStartOffset=25017808562,
recordErrors=[], errorMessage=null)])], throttleTimeMs=0)
2022-07-06T21:56:34,580 DEBUG [kafka-producer-network-thread | producer-1]
org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1]
Received PRODUCE response from node 2 for request with header
RequestHeader(apiKey=PRODUCE, apiVersion=9, clientId=producer-1,
correlationId=1555):
ProduceResponseData(responses=[TopicProduceResponse(name='druid_metrics',
partitionResponses=[PartitionProduceResponse(index=5, errorCode=0,
baseOffset=24899662987, logAppendTimeMs=-1, logStartOffset=24595386343,
recordErrors=[], errorMessage=null)])], throttleTimeMs=0)
...
...
# "/pause" with 202 Accepted response comes in (this is the pause that never
had the debug log output so it never seemed to have actually paused)
2022-07-06T21:56:35,617 DEBUG [qtp323665272-156]
org.eclipse.jetty.server.HttpChannel - COMMIT for
/druid/worker/v1/chat/index_kafka_REDACT_a5c10ee5effa63e_bhjndmoc/pause on
HttpChannelOverHttp@427bc76a{s=HttpChannelState@2d006490{s=HANDLING rs=BLOCKING
os=COMMITTED is=IDLE awp=false se=false i=true
al=0},r=1,c=false/false,a=HANDLING,uri=//REDACTED.host.com:8100/druid/worker/v1/chat/index_kafka_REDACT_a5c10ee5effa63e_bhjndmoc/pause,age=2002}
202 Accepted HTTP/1.1
Date: Wed, 06 Jul 2022 21:56:33 GMT
X-Druid-Task-Id: index_kafka_REDACT_a5c10ee5effa63e_bhjndmoc
Content-Type: application/json
Vary: Accept-Encoding, User-Agent
Content-Encoding: gzip
...
...
2022-07-06T21:57:30,548 DEBUG [kafka-producer-network-thread | producer-1]
org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending
PRODUCE request with header RequestHeader(apiKey=PRODUCE, apiVersion=9,
clientId=producer-1, correlationId=1556) and timeout 30000 to node 1:
{acks=1,timeout=30000,partitionSizes=[druid_metrics-1=1108]}
2022-07-06T21:57:30,548 DEBUG [kafka-producer-network-thread | producer-1]
org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending
PRODUCE request with header RequestHeader(apiKey=PRODUCE, apiVersion=9,
clientId=producer-1, correlationId=1557) and timeout 30000 to node 1:
{acks=1,timeout=30000,partitionSizes=[druid_metrics-4=5413]}
2022-07-06T21:57:30,549 DEBUG [kafka-producer-network-thread | producer-1]
org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1]
Received PRODUCE response from node 1 for request with header
RequestHeader(apiKey=PRODUCE, apiVersion=9, clientId=producer-1,
correlationId=1556):
ProduceResponseData(responses=[TopicProduceResponse(name='druid_metrics',
partitionResponses=[PartitionProduceResponse(index=1, errorCode=0,
baseOffset=25339711296, logAppendTimeMs=-1, logStartOffset=25042925030,
recordErrors=[], errorMessage=null)])], throttleTimeMs=0)
2022-07-06T21:57:30,549 DEBUG [kafka-producer-network-thread | producer-1]
org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1]
Received PRODUCE response from node 1 for request with header
RequestHeader(apiKey=PRODUCE, apiVersion=9, clientId=producer-1,
correlationId=1557):
ProduceResponseData(responses=[TopicProduceResponse(name='druid_metrics',
partitionResponses=[PartitionProduceResponse(index=4, errorCode=0,
baseOffset=25318452392, logAppendTimeMs=-1, logStartOffset=25017808562,
recordErrors=[], errorMessage=null)])], throttleTimeMs=0)
2022-07-06T21:57:30,549 DEBUG [kafka-producer-network-thread | producer-1]
org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending
PRODUCE request with header RequestHeader(apiKey=PRODUCE, apiVersion=9,
clientId=producer-1, correlationId=1558) and timeout 30000 to node 2:
{acks=1,timeout=30000,partitionSizes=[druid_metrics-2=881]}
2022-07-06T21:57:30,550 DEBUG [kafka-producer-network-thread | producer-1]
org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending
PRODUCE request with header RequestHeader(apiKey=PRODUCE, apiVersion=9,
clientId=producer-1, correlationId=1559) and timeout 30000 to node 2:
{acks=1,timeout=30000,partitionSizes=[druid_metrics-5=338]}
2022-07-06T21:57:30,550 DEBUG [kafka-producer-network-thread | producer-1]
org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending
PRODUCE request with header RequestHeader(apiKey=PRODUCE, apiVersion=9,
clientId=producer-1, correlationId=1560) and timeout 30000 to node 2:
{acks=1,timeout=30000,partitionSizes=[druid_metrics-2=1539]}
2022-07-06T21:57:30,551 DEBUG [kafka-producer-network-thread | producer-1]
org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending
PRODUCE request with header RequestHeader(apiKey=PRODUCE, apiVersion=9,
clientId=producer-1, correlationId=1561) and timeout 30000 to node 1:
{acks=1,timeout=30000,partitionSizes=[druid_metrics-4=3533]}
2022-07-06T21:57:30,551 DEBUG [kafka-producer-network-thread | producer-1]
org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1]
Received PRODUCE response from node 2 for request with header
RequestHeader(apiKey=PRODUCE, apiVersion=9, clientId=producer-1,
correlationId=1558):
ProduceResponseData(responses=[TopicProduceResponse(name='druid_metrics',
partitionResponses=[PartitionProduceResponse(index=2, errorCode=0,
baseOffset=24961032971, logAppendTimeMs=-1, logStartOffset=24662686084,
recordErrors=[], errorMessage=null)])], throttleTimeMs=0)
2022-07-06T21:57:30,551 DEBUG [kafka-producer-network-thread | producer-1]
org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending
PRODUCE request with header RequestHeader(apiKey=PRODUCE, apiVersion=9,
clientId=producer-1, correlationId=1562) and timeout 30000 to node 3:
{acks=1,timeout=30000,partitionSizes=[druid_metrics-0=3029]}
2022-07-06T21:57:30,551 DEBUG [kafka-producer-network-thread | producer-1]
org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1]
Received PRODUCE response from node 2 for request with header
RequestHeader(apiKey=PRODUCE, apiVersion=9, clientId=producer-1,
correlationId=1559):
ProduceResponseData(responses=[TopicProduceResponse(name='druid_metrics',
partitionResponses=[PartitionProduceResponse(index=5, errorCode=0,
baseOffset=24900072463, logAppendTimeMs=-1, logStartOffset=24595386343,
recordErrors=[], errorMessage=null)])], throttleTimeMs=0)
2022-07-06T21:57:30,551 DEBUG [kafka-producer-network-thread | producer-1]
org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending
PRODUCE request with header RequestHeader(apiKey=PRODUCE, apiVersion=9,
clientId=producer-1, correlationId=1563) and timeout 30000 to node 1:
{acks=1,timeout=30000,partitionSizes=[druid_metrics-1=2338]}
2022-07-06T21:57:30,551 DEBUG [kafka-producer-network-thread | producer-1]
org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending
PRODUCE request with header RequestHeader(apiKey=PRODUCE, apiVersion=9,
clientId=producer-1, correlationId=1564) and timeout 30000 to node 2:
{acks=1,timeout=30000,partitionSizes=[druid_metrics-2=5711]}
2022-07-06T21:57:30,551 DEBUG [kafka-producer-network-thread | producer-1]
org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending
PRODUCE request with header RequestHeader(apiKey=PRODUCE, apiVersion=9,
clientId=producer-1, correlationId=1565) and timeout 30000 to node 3:
{acks=1,timeout=30000,partitionSizes=[druid_metrics-3=3040]}
2022-07-06T21:57:30,551 DEBUG [kafka-producer-network-thread | producer-1]
org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Sending
PRODUCE request with header RequestHeader(apiKey=PRODUCE, apiVersion=9,
clientId=producer-1, correlationId=1566) and timeout 30000 to node 1:
{acks=1,timeout=30000,partitionSizes=[druid_metrics-4=853]}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
