2020-04-24 15:23:42,196 WARN  [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-63] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Error connecting to node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)
java.net.UnknownHostException: kafka-a-0.kafka.default.svc.cluster.local
	at java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)
	at java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1505)
	at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1364)
	at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1298)
	at org.apache.kafka.clients.ClientUtils.resolve(ClientUtils.java:104)
	at org.apache.kafka.clients.ClusterConnectionStates$NodeConnectionState.currentAddress(ClusterConnectionStates.java:403)
	at org.apache.kafka.clients.ClusterConnectionStates$NodeConnectionState.access$200(ClusterConnectionStates.java:363)
	at org.apache.kafka.clients.ClusterConnectionStates.currentAddress(ClusterConnectionStates.java:151)
	at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:955)
	at org.apache.kafka.clients.NetworkClient.ready(NetworkClient.java:289)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.trySend(ConsumerNetworkClient.java:495)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:252)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:233)
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:212)
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:230)
	at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:444)
	at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1267)
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1231)
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1211)
	at akka.kafka.internal.KafkaConsumerActor.poll(KafkaConsumerActor.scala:537)
	at akka.kafka.internal.KafkaConsumerActor.akka$kafka$internal$KafkaConsumerActor$$receivePoll(KafkaConsumerActor.scala:496)
	at akka.kafka.internal.KafkaConsumerActor$$anonfun$regularReceive$1.applyOrElse(KafkaConsumerActor.scala:286)
	at akka.actor.Actor.aroundReceive(Actor.scala:539)
	at akka.actor.Actor.aroundReceive$(Actor.scala:537)
	at akka.kafka.internal.KafkaConsumerActor.akka$actor$Timers$$super$aroundReceive(KafkaConsumerActor.scala:205)
	at akka.actor.Timers.aroundReceive(Timers.scala:51)
	at akka.actor.Timers.aroundReceive$(Timers.scala:40)
	at akka.kafka.internal.KafkaConsumerActor.aroundReceive(KafkaConsumerActor.scala:205)
	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:612)
	at akka.actor.ActorCell.invoke(ActorCell.scala:581)
	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:268)
	at akka.dispatch.Mailbox.run(Mailbox.scala:229)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:834)
2020-04-24 15:23:42,196 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-63] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,196 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-63] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,196 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-63] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:42,196 DEBUG [o.a.k.c.c.i.ConsumerNetworkClient] [tcgd-akka.kafka.default-dispatcher-63] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Cancelled request with header RequestHeader(apiKey=FIND_COORDINATOR, apiVersion=3, clientId=consumer-tfp-9-6, correlationId=2337) due to node 0 being disconnected
2020-04-24 15:23:42,196 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-63] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Coordinator discovery failed, refreshing metadata
2020-04-24 15:23:42,196 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-63] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,196 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-63] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,196 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-63] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:42,196 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-63] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,196 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-63] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,196 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-63] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:42,201 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,201 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,201 DEBUG [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Give up sending metadata request since no node is available
2020-04-24 15:23:42,251 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,251 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,251 DEBUG [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Give up sending metadata request since no node is available
2020-04-24 15:23:42,302 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,302 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,302 DEBUG [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Give up sending metadata request since no node is available
2020-04-24 15:23:42,315 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-55] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,316 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-55] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,316 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-55] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] No broker available to send FindCoordinator request
2020-04-24 15:23:42,316 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-55] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,316 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-55] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,316 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-55] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:42,316 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-55] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Coordinator discovery failed, refreshing metadata
2020-04-24 15:23:42,316 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-55] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,316 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-55] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,316 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-55] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:42,352 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,352 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,352 DEBUG [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Give up sending metadata request since no node is available
2020-04-24 15:23:42,402 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Found least loaded node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) with no active connection
2020-04-24 15:23:42,402 DEBUG [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Initialize connection to node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) for sending metadata request
2020-04-24 15:23:42,402 DEBUG [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Initiating connection to node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) using address kafka-a-0.kafka.default.svc.cluster.local/172.17.0.7
2020-04-24 15:23:42,405 DEBUG [o.a.k.c.n.Selector] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Created socket with SO_RCVBUF = 32768, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 0
2020-04-24 15:23:42,405 DEBUG [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Completed connection to node 0. Fetching API versions.
2020-04-24 15:23:42,405 DEBUG [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Initiating API versions fetch from node 0.
2020-04-24 15:23:42,405 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] No version information found when sending API_VERSIONS with correlation id 2332 to node 0. Assuming version 3.
2020-04-24 15:23:42,405 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Sending API_VERSIONS {client_software_name=apache-kafka-java,client_software_version=2.4.0,_tagged_fields={}} with correlation id 2332 to node 0
2020-04-24 15:23:42,405 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Found least loaded connecting node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)
2020-04-24 15:23:42,405 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Found least loaded connecting node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)
2020-04-24 15:23:42,408 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Completed receive from node 0 for API_VERSIONS with correlation id 2332, received {error_code=35,api_keys=[]}
2020-04-24 15:23:42,409 DEBUG [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Initiating API versions fetch from node 0.
2020-04-24 15:23:42,409 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] No version information found when sending API_VERSIONS with correlation id 2333 to node 0. Assuming version 0.
2020-04-24 15:23:42,409 DEBUG [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Using older server API v0 to send API_VERSIONS {} with correlation id 2333 to node 0
2020-04-24 15:23:42,409 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Found least loaded connecting node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)
2020-04-24 15:23:42,411 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Found least loaded connecting node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)
2020-04-24 15:23:42,411 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Completed receive from node 0 for API_VERSIONS with correlation id 2333, received {error_code=0,api_keys=[{api_key=0,min_version=0,max_version=7},{api_key=1,min_version=0,max_version=11},{api_key=2,min_version=0,max_version=5},{api_key=3,min_version=0,max_version=8},{api_key=4,min_version=0,max_version=2},{api_key=5,min_version=0,max_version=1},{api_key=6,min_version=0,max_version=5},{api_key=7,min_version=0,max_version=2},{api_key=8,min_version=0,max_version=7},{api_key=9,min_version=0,max_version=5},{api_key=10,min_version=0,max_version=2},{api_key=11,min_version=0,max_version=5},{api_key=12,min_version=0,max_version=3},{api_key=13,min_version=0,max_version=2},{api_key=14,min_version=0,max_version=3},{api_key=15,min_version=0,max_version=3},{api_key=16,min_version=0,max_version=2},{api_key=17,min_version=0,max_version=1},{api_key=18,min_version=0,max_version=2},{api_key=19,min_version=0,max_version=3},{api_key=20,min_version=0,max_version=3},{api_key=21,min_version=0,max_version=1},{api_key=22,min_version=0,max_version=1},{api_key=23,min_version=0,max_version=3},{api_key=24,min_version=0,max_version=1},{api_key=25,min_version=0,max_version=1},{api_key=26,min_version=0,max_version=1},{api_key=27,min_version=0,max_version=0},{api_key=28,min_version=0,max_version=2},{api_key=29,min_version=0,max_version=1},{api_key=30,min_version=0,max_version=1},{api_key=31,min_version=0,max_version=1},{api_key=32,min_version=0,max_version=2},{api_key=33,min_version=0,max_version=1},{api_key=34,min_version=0,max_version=1},{api_key=35,min_version=0,max_version=1},{api_key=36,min_version=0,max_version=1},{api_key=37,min_version=0,max_version=1},{api_key=38,min_version=0,max_version=1},{api_key=39,min_version=0,max_version=1},{api_key=40,min_version=0,max_version=1},{api_key=41,min_version=0,max_version=1},{api_key=42,min_version=0,max_version=1},{api_key=43,min_version=0,max_version=0},{api_key=44,min_version=0,max_version=0}]}
2020-04-24 15:23:42,412 DEBUG [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Recorded API versions for node 0: (Produce(0): 0 to 7 [usable: 7], Fetch(1): 0 to 11 [usable: 11], ListOffsets(2): 0 to 5 [usable: 5], Metadata(3): 0 to 8 [usable: 8], LeaderAndIsr(4): 0 to 2 [usable: 2], StopReplica(5): 0 to 1 [usable: 1], UpdateMetadata(6): 0 to 5 [usable: 5], ControlledShutdown(7): 0 to 2 [usable: 2], OffsetCommit(8): 0 to 7 [usable: 7], OffsetFetch(9): 0 to 5 [usable: 5], FindCoordinator(10): 0 to 2 [usable: 2], JoinGroup(11): 0 to 5 [usable: 5], Heartbeat(12): 0 to 3 [usable: 3], LeaveGroup(13): 0 to 2 [usable: 2], SyncGroup(14): 0 to 3 [usable: 3], DescribeGroups(15): 0 to 3 [usable: 3], ListGroups(16): 0 to 2 [usable: 2], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 2 [usable: 2], CreateTopics(19): 0 to 3 [usable: 3], DeleteTopics(20): 0 to 3 [usable: 3], DeleteRecords(21): 0 to 1 [usable: 1], InitProducerId(22): 0 to 1 [usable: 1], OffsetForLeaderEpoch(23): 0 to 3 [usable: 3], AddPartitionsToTxn(24): 0 to 1 [usable: 1], AddOffsetsToTxn(25): 0 to 1 [usable: 1], EndTxn(26): 0 to 1 [usable: 1], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 to 2 [usable: 2], DescribeAcls(29): 0 to 1 [usable: 1], CreateAcls(30): 0 to 1 [usable: 1], DeleteAcls(31): 0 to 1 [usable: 1], DescribeConfigs(32): 0 to 2 [usable: 2], AlterConfigs(33): 0 to 1 [usable: 1], AlterReplicaLogDirs(34): 0 to 1 [usable: 1], DescribeLogDirs(35): 0 to 1 [usable: 1], SaslAuthenticate(36): 0 to 1 [usable: 1], CreatePartitions(37): 0 to 1 [usable: 1], CreateDelegationToken(38): 0 to 1 [usable: 1], RenewDelegationToken(39): 0 to 1 [usable: 1], ExpireDelegationToken(40): 0 to 1 [usable: 1], DescribeDelegationToken(41): 0 to 1 [usable: 1], DeleteGroups(42): 0 to 1 [usable: 1], ElectLeaders(43): 0 [usable: 0], IncrementalAlterConfigs(44): 0 [usable: 0], AlterPartitionReassignments(45): UNSUPPORTED, ListPartitionReassignments(46): UNSUPPORTED, OffsetDelete(47): UNSUPPORTED)
2020-04-24 15:23:42,412 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Found least loaded node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) connected with no in-flight requests
2020-04-24 15:23:42,412 DEBUG [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Sending metadata request MetadataRequestData(topics=[], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)
2020-04-24 15:23:42,412 DEBUG [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Using older server API v8 to send METADATA {topics=[],allow_auto_topic_creation=true,include_cluster_authorized_operations=false,include_topic_authorized_operations=false} with correlation id 2334 to node 0
2020-04-24 15:23:42,416 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Completed receive from node 0 for METADATA with correlation id 2334, received {throttle_time_ms=0,brokers=[{node_id=0,host=kafka-a-0.kafka.default.svc.cluster.local,port=9092,rack=null}],cluster_id=CR-fk2KUTk-knBM_rwsdXg,controller_id=0,topics=[],cluster_authorized_operations=0}
2020-04-24 15:23:42,416 DEBUG [o.a.k.c.Metadata] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Updated cluster metadata updateVersion 18 to MetadataCache{clusterId='CR-fk2KUTk-knBM_rwsdXg', nodes=[kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)], partitions=[], controller=kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)}
2020-04-24 15:23:42,426 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-51] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,426 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-51] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,426 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-51] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] No broker available to send FindCoordinator request
2020-04-24 15:23:42,426 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-51] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,426 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-51] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,426 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-51] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:42,427 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-51] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Coordinator discovery failed, refreshing metadata
2020-04-24 15:23:42,427 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-51] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,427 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-51] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,427 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-51] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:42,545 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-60] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,545 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-60] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,545 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-60] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] No broker available to send FindCoordinator request
2020-04-24 15:23:42,545 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-60] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,545 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-60] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,545 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-60] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:42,545 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-60] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Coordinator discovery failed, refreshing metadata
2020-04-24 15:23:42,545 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-60] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,545 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-60] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,545 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-60] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:42,655 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-62] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,655 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-62] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,655 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-62] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] No broker available to send FindCoordinator request
2020-04-24 15:23:42,655 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-62] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,658 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-62] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,658 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-62] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:42,658 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-62] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Coordinator discovery failed, refreshing metadata
2020-04-24 15:23:42,658 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-62] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,660 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-62] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,661 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-62] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:42,778 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-54] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,778 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-54] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,778 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-54] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] No broker available to send FindCoordinator request
2020-04-24 15:23:42,778 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-54] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,778 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-54] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,778 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-54] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:42,793 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-54] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Coordinator discovery failed, refreshing metadata
2020-04-24 15:23:42,793 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-54] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,793 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-54] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,793 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-54] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:42,905 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-52] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,905 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-52] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,905 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-52] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] No broker available to send FindCoordinator request
2020-04-24 15:23:42,905 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-52] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,905 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-52] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,905 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-52] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:42,905 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-52] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Coordinator discovery failed, refreshing metadata
2020-04-24 15:23:42,905 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-52] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:42,905 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-52] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:42,905 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-52] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:43,028 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-61] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:43,029 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-61] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:43,029 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-61] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] No broker available to send FindCoordinator request
2020-04-24 15:23:43,029 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-61] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:43,029 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-61] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:43,029 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-61] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:43,029 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-61] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Coordinator discovery failed, refreshing metadata
2020-04-24 15:23:43,030 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-61] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:43,030 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-61] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:43,030 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-61] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:43,145 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-59] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:43,145 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-59] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:43,145 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-59] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] No broker available to send FindCoordinator request
2020-04-24 15:23:43,145 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-59] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:43,145 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-59] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:43,145 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-59] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:43,145 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-59] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Coordinator discovery failed, refreshing metadata
2020-04-24 15:23:43,145 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-59] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:43,145 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-59] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:43,145 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-59] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:43,268 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-48] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:43,268 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-48] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:43,269 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-48] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] No broker available to send FindCoordinator request
2020-04-24 15:23:43,270 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-48] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:43,271 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-48] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:43,272 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-48] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:43,272 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-48] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Coordinator discovery failed, refreshing metadata
2020-04-24 15:23:43,272 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-48] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Removing node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) from least loaded node selection since it is neither ready for sending or connecting
2020-04-24 15:23:43,272 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-48] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Least loaded node selection failed to find an available node
2020-04-24 15:23:43,272 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-48] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Give up sending metadata request since no node is available
2020-04-24 15:23:43,385 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Found least loaded node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) with no active connection
2020-04-24 15:23:43,385 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Sending FindCoordinator request to broker kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)
2020-04-24 15:23:43,385 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Initiating connection to node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) using address kafka-a-0.kafka.default.svc.cluster.local/172.17.0.7
2020-04-24 15:23:43,386 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Found least loaded connecting node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)
2020-04-24 15:23:43,387 DEBUG [o.a.k.c.n.Selector] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 0
2020-04-24 15:23:43,387 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Completed connection to node 0. Fetching API versions.
2020-04-24 15:23:43,387 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Initiating API versions fetch from node 0.
2020-04-24 15:23:43,387 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] No version information found when sending API_VERSIONS with correlation id 2339 to node 0. Assuming version 3.
2020-04-24 15:23:43,387 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Sending API_VERSIONS {client_software_name=apache-kafka-java,client_software_version=2.4.0,_tagged_fields={}} with correlation id 2339 to node 0
2020-04-24 15:23:43,387 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Found least loaded connecting node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)
2020-04-24 15:23:43,387 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Found least loaded connecting node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)
2020-04-24 15:23:43,391 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Completed receive from node 0 for API_VERSIONS with correlation id 2339, received {error_code=35,api_keys=[]}
2020-04-24 15:23:43,391 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Initiating API versions fetch from node 0.
2020-04-24 15:23:43,391 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] No version information found when sending API_VERSIONS with correlation id 2340 to node 0. Assuming version 0.
2020-04-24 15:23:43,391 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Using older server API v0 to send API_VERSIONS {} with correlation id 2340 to node 0
2020-04-24 15:23:43,391 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Found least loaded connecting node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)
2020-04-24 15:23:43,391 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Found least loaded connecting node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)
2020-04-24 15:23:43,392 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Completed receive from node 0 for API_VERSIONS with correlation id 2340, received {error_code=0,api_keys=[{api_key=0,min_version=0,max_version=7},{api_key=1,min_version=0,max_version=11},{api_key=2,min_version=0,max_version=5},{api_key=3,min_version=0,max_version=8},{api_key=4,min_version=0,max_version=2},{api_key=5,min_version=0,max_version=1},{api_key=6,min_version=0,max_version=5},{api_key=7,min_version=0,max_version=2},{api_key=8,min_version=0,max_version=7},{api_key=9,min_version=0,max_version=5},{api_key=10,min_version=0,max_version=2},{api_key=11,min_version=0,max_version=5},{api_key=12,min_version=0,max_version=3},{api_key=13,min_version=0,max_version=2},{api_key=14,min_version=0,max_version=3},{api_key=15,min_version=0,max_version=3},{api_key=16,min_version=0,max_version=2},{api_key=17,min_version=0,max_version=1},{api_key=18,min_version=0,max_version=2},{api_key=19,min_version=0,max_version=3},{api_key=20,min_version=0,max_version=3},{api_key=21,min_version=0,max_version=1},{api_key=22,min_version=0,max_version=1},{api_key=23,min_version=0,max_version=3},{api_key=24,min_version=0,max_version=1},{api_key=25,min_version=0,max_version=1},{api_key=26,min_version=0,max_version=1},{api_key=27,min_version=0,max_version=0},{api_key=28,min_version=0,max_version=2},{api_key=29,min_version=0,max_version=1},{api_key=30,min_version=0,max_version=1},{api_key=31,min_version=0,max_version=1},{api_key=32,min_version=0,max_version=2},{api_key=33,min_version=0,max_version=1},{api_key=34,min_version=0,max_version=1},{api_key=35,min_version=0,max_version=1},{api_key=36,min_version=0,max_version=1},{api_key=37,min_version=0,max_version=1},{api_key=38,min_version=0,max_version=1},{api_key=39,min_version=0,max_version=1},{api_key=40,min_version=0,max_version=1},{api_key=41,min_version=0,max_version=1},{api_key=42,min_version=0,max_version=1},{api_key=43,min_version=0,max_version=0},{api_key=44,min_version=0,max_version=0}]}
2020-04-24 15:23:43,393 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Recorded API versions for node 0: (Produce(0): 0 to 7 [usable: 7], Fetch(1): 0 to 11 [usable: 11], ListOffsets(2): 0 to 5 [usable: 5], Metadata(3): 0 to 8 [usable: 8], LeaderAndIsr(4): 0 to 2 [usable: 2], StopReplica(5): 0 to 1 [usable: 1], UpdateMetadata(6): 0 to 5 [usable: 5], ControlledShutdown(7): 0 to 2 [usable: 2], OffsetCommit(8): 0 to 7 [usable: 7], OffsetFetch(9): 0 to 5 [usable: 5], FindCoordinator(10): 0 to 2 [usable: 2], JoinGroup(11): 0 to 5 [usable: 5], Heartbeat(12): 0 to 3 [usable: 3], LeaveGroup(13): 0 to 2 [usable: 2], SyncGroup(14): 0 to 3 [usable: 3], DescribeGroups(15): 0 to 3 [usable: 3], ListGroups(16): 0 to 2 [usable: 2], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 2 [usable: 2], CreateTopics(19): 0 to 3 [usable: 3], DeleteTopics(20): 0 to 3 [usable: 3], DeleteRecords(21): 0 to 1 [usable: 1], InitProducerId(22): 0 to 1 [usable: 1], OffsetForLeaderEpoch(23): 0 to 3 [usable: 3], AddPartitionsToTxn(24): 0 to 1 [usable: 1], AddOffsetsToTxn(25): 0 to 1 [usable: 1], EndTxn(26): 0 to 1 [usable: 1], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 to 2 [usable: 2], DescribeAcls(29): 0 to 1 [usable: 1], CreateAcls(30): 0 to 1 [usable: 1], DeleteAcls(31): 0 to 1 [usable: 1], DescribeConfigs(32): 0 to 2 [usable: 2], AlterConfigs(33): 0 to 1 [usable: 1], AlterReplicaLogDirs(34): 0 to 1 [usable: 1], DescribeLogDirs(35): 0 to 1 [usable: 1], SaslAuthenticate(36): 0 to 1 [usable: 1], CreatePartitions(37): 0 to 1 [usable: 1], CreateDelegationToken(38): 0 to 1 [usable: 1], RenewDelegationToken(39): 0 to 1 [usable: 1], ExpireDelegationToken(40): 0 to 1 [usable: 1], DescribeDelegationToken(41): 0 to 1 [usable: 1], DeleteGroups(42): 0 to 1 [usable: 1], ElectLeaders(43): 0 [usable: 0], IncrementalAlterConfigs(44): 0 [usable: 0], AlterPartitionReassignments(45): UNSUPPORTED, ListPartitionReassignments(46): UNSUPPORTED, OffsetDelete(47): UNSUPPORTED)
2020-04-24 15:23:43,393 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Found least loaded node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) connected with no in-flight requests
2020-04-24 15:23:43,393 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Sending metadata request MetadataRequestData(topics=[MetadataRequestTopic(name='increasing-topic-0')], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)
2020-04-24 15:23:43,393 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Using older server API v8 to send METADATA {topics=[{name=increasing-topic-0}],allow_auto_topic_creation=true,include_cluster_authorized_operations=false,include_topic_authorized_operations=false} with correlation id 2341 to node 0
2020-04-24 15:23:43,393 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Using older server API v2 to send FIND_COORDINATOR {key=tfp-9,key_type=0} with correlation id 2338 to node 0
2020-04-24 15:23:43,396 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Completed receive from node 0 for METADATA with correlation id 2341, received {throttle_time_ms=0,brokers=[{node_id=0,host=kafka-a-0.kafka.default.svc.cluster.local,port=9092,rack=null}],cluster_id=CR-fk2KUTk-knBM_rwsdXg,controller_id=0,topics=[{error_code=0,name=increasing-topic-0,is_internal=false,partitions=[{error_code=0,partition_index=0,leader_id=0,leader_epoch=0,replica_nodes=[0],isr_nodes=[0],offline_replicas=[]}],topic_authorized_operations=0}],cluster_authorized_operations=0}
2020-04-24 15:23:43,398 DEBUG [o.a.k.c.Metadata] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Updated cluster metadata updateVersion 38 to MetadataCache{clusterId='CR-fk2KUTk-knBM_rwsdXg', nodes=[kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)], partitions=[PartitionInfoAndEpoch{partitionInfo=Partition(topic = increasing-topic-0, partition = 0, leader = 0, replicas = [0], isr = [0], offlineReplicas = []), epoch=-1}], controller=kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)}
2020-04-24 15:23:43,409 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Completed receive from node 0 for FIND_COORDINATOR with correlation id 2338, received {throttle_time_ms=0,error_code=0,error_message=NONE,node_id=0,host=kafka-a-0.kafka.default.svc.cluster.local,port=9092}
2020-04-24 15:23:43,409 DEBUG [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Received FindCoordinator response ClientResponse(receivedTimeMs=1587741823409, latencyMs=24, disconnected=false, requestHeader=RequestHeader(apiKey=FIND_COORDINATOR, apiVersion=2, clientId=consumer-tfp-9-6, correlationId=2338), responseBody=FindCoordinatorResponseData(throttleTimeMs=0, errorCode=0, errorMessage='NONE', nodeId=0, host='kafka-a-0.kafka.default.svc.cluster.local', port=9092))
2020-04-24 15:23:43,409 INFO  [o.a.k.c.c.i.AbstractCoordinator] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Discovered group coordinator kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 2147483647 rack: null)
2020-04-24 15:23:43,409 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Initiating connection to node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 2147483647 rack: null) using address kafka-a-0.kafka.default.svc.cluster.local/172.17.0.7
2020-04-24 15:23:43,410 DEBUG [o.a.k.c.n.Selector] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node 2147483647
2020-04-24 15:23:43,410 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Completed connection to node 2147483647. Fetching API versions.
2020-04-24 15:23:43,410 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Initiating API versions fetch from node 2147483647.
2020-04-24 15:23:43,410 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] No version information found when sending API_VERSIONS with correlation id 2342 to node 2147483647. Assuming version 3.
2020-04-24 15:23:43,410 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Sending API_VERSIONS {client_software_name=apache-kafka-java,client_software_version=2.4.0,_tagged_fields={}} with correlation id 2342 to node 2147483647
2020-04-24 15:23:43,411 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Completed receive from node 2147483647 for API_VERSIONS with correlation id 2342, received {error_code=35,api_keys=[]}
2020-04-24 15:23:43,411 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Initiating API versions fetch from node 2147483647.
2020-04-24 15:23:43,412 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] No version information found when sending API_VERSIONS with correlation id 2343 to node 2147483647. Assuming version 0.
2020-04-24 15:23:43,412 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Using older server API v0 to send API_VERSIONS {} with correlation id 2343 to node 2147483647
2020-04-24 15:23:43,416 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Completed receive from node 2147483647 for API_VERSIONS with correlation id 2343, received {error_code=0,api_keys=[{api_key=0,min_version=0,max_version=7},{api_key=1,min_version=0,max_version=11},{api_key=2,min_version=0,max_version=5},{api_key=3,min_version=0,max_version=8},{api_key=4,min_version=0,max_version=2},{api_key=5,min_version=0,max_version=1},{api_key=6,min_version=0,max_version=5},{api_key=7,min_version=0,max_version=2},{api_key=8,min_version=0,max_version=7},{api_key=9,min_version=0,max_version=5},{api_key=10,min_version=0,max_version=2},{api_key=11,min_version=0,max_version=5},{api_key=12,min_version=0,max_version=3},{api_key=13,min_version=0,max_version=2},{api_key=14,min_version=0,max_version=3},{api_key=15,min_version=0,max_version=3},{api_key=16,min_version=0,max_version=2},{api_key=17,min_version=0,max_version=1},{api_key=18,min_version=0,max_version=2},{api_key=19,min_version=0,max_version=3},{api_key=20,min_version=0,max_version=3},{api_key=21,min_version=0,max_version=1},{api_key=22,min_version=0,max_version=1},{api_key=23,min_version=0,max_version=3},{api_key=24,min_version=0,max_version=1},{api_key=25,min_version=0,max_version=1},{api_key=26,min_version=0,max_version=1},{api_key=27,min_version=0,max_version=0},{api_key=28,min_version=0,max_version=2},{api_key=29,min_version=0,max_version=1},{api_key=30,min_version=0,max_version=1},{api_key=31,min_version=0,max_version=1},{api_key=32,min_version=0,max_version=2},{api_key=33,min_version=0,max_version=1},{api_key=34,min_version=0,max_version=1},{api_key=35,min_version=0,max_version=1},{api_key=36,min_version=0,max_version=1},{api_key=37,min_version=0,max_version=1},{api_key=38,min_version=0,max_version=1},{api_key=39,min_version=0,max_version=1},{api_key=40,min_version=0,max_version=1},{api_key=41,min_version=0,max_version=1},{api_key=42,min_version=0,max_version=1},{api_key=43,min_version=0,max_version=0},{api_key=44,min_version=0,max_version=0}]}
2020-04-24 15:23:43,416 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Recorded API versions for node 2147483647: (Produce(0): 0 to 7 [usable: 7], Fetch(1): 0 to 11 [usable: 11], ListOffsets(2): 0 to 5 [usable: 5], Metadata(3): 0 to 8 [usable: 8], LeaderAndIsr(4): 0 to 2 [usable: 2], StopReplica(5): 0 to 1 [usable: 1], UpdateMetadata(6): 0 to 5 [usable: 5], ControlledShutdown(7): 0 to 2 [usable: 2], OffsetCommit(8): 0 to 7 [usable: 7], OffsetFetch(9): 0 to 5 [usable: 5], FindCoordinator(10): 0 to 2 [usable: 2], JoinGroup(11): 0 to 5 [usable: 5], Heartbeat(12): 0 to 3 [usable: 3], LeaveGroup(13): 0 to 2 [usable: 2], SyncGroup(14): 0 to 3 [usable: 3], DescribeGroups(15): 0 to 3 [usable: 3], ListGroups(16): 0 to 2 [usable: 2], SaslHandshake(17): 0 to 1 [usable: 1], ApiVersions(18): 0 to 2 [usable: 2], CreateTopics(19): 0 to 3 [usable: 3], DeleteTopics(20): 0 to 3 [usable: 3], DeleteRecords(21): 0 to 1 [usable: 1], InitProducerId(22): 0 to 1 [usable: 1], OffsetForLeaderEpoch(23): 0 to 3 [usable: 3], AddPartitionsToTxn(24): 0 to 1 [usable: 1], AddOffsetsToTxn(25): 0 to 1 [usable: 1], EndTxn(26): 0 to 1 [usable: 1], WriteTxnMarkers(27): 0 [usable: 0], TxnOffsetCommit(28): 0 to 2 [usable: 2], DescribeAcls(29): 0 to 1 [usable: 1], CreateAcls(30): 0 to 1 [usable: 1], DeleteAcls(31): 0 to 1 [usable: 1], DescribeConfigs(32): 0 to 2 [usable: 2], AlterConfigs(33): 0 to 1 [usable: 1], AlterReplicaLogDirs(34): 0 to 1 [usable: 1], DescribeLogDirs(35): 0 to 1 [usable: 1], SaslAuthenticate(36): 0 to 1 [usable: 1], CreatePartitions(37): 0 to 1 [usable: 1], CreateDelegationToken(38): 0 to 1 [usable: 1], RenewDelegationToken(39): 0 to 1 [usable: 1], ExpireDelegationToken(40): 0 to 1 [usable: 1], DescribeDelegationToken(41): 0 to 1 [usable: 1], DeleteGroups(42): 0 to 1 [usable: 1], ElectLeaders(43): 0 [usable: 0], IncrementalAlterConfigs(44): 0 [usable: 0], AlterPartitionReassignments(45): UNSUPPORTED, ListPartitionReassignments(46): UNSUPPORTED, OffsetDelete(47): UNSUPPORTED)
2020-04-24 15:28:42,445 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Found least loaded node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) connected with no in-flight requests
2020-04-24 15:28:42,445 DEBUG [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Sending metadata request MetadataRequestData(topics=[], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)
2020-04-24 15:28:42,445 DEBUG [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Using older server API v8 to send METADATA {topics=[],allow_auto_topic_creation=true,include_cluster_authorized_operations=false,include_topic_authorized_operations=false} with correlation id 2335 to node 0
2020-04-24 15:28:42,448 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Completed receive from node 0 for METADATA with correlation id 2335, received {throttle_time_ms=0,brokers=[{node_id=0,host=kafka-a-0.kafka.default.svc.cluster.local,port=9092,rack=null}],cluster_id=CR-fk2KUTk-knBM_rwsdXg,controller_id=0,topics=[],cluster_authorized_operations=0}
2020-04-24 15:28:42,449 DEBUG [o.a.k.c.Metadata] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Updated cluster metadata updateVersion 19 to MetadataCache{clusterId='CR-fk2KUTk-knBM_rwsdXg', nodes=[kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)], partitions=[], controller=kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)}
2020-04-24 15:28:43,397 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-61] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Found least loaded node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) connected with no in-flight requests
2020-04-24 15:28:43,397 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-61] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Sending metadata request MetadataRequestData(topics=[MetadataRequestTopic(name='increasing-topic-0')], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)
2020-04-24 15:28:43,397 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-61] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Using older server API v8 to send METADATA {topics=[{name=increasing-topic-0}],allow_auto_topic_creation=true,include_cluster_authorized_operations=false,include_topic_authorized_operations=false} with correlation id 2344 to node 0
2020-04-24 15:28:43,398 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-61] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Completed receive from node 0 for METADATA with correlation id 2344, received {throttle_time_ms=0,brokers=[{node_id=0,host=kafka-a-0.kafka.default.svc.cluster.local,port=9092,rack=null}],cluster_id=CR-fk2KUTk-knBM_rwsdXg,controller_id=0,topics=[{error_code=0,name=increasing-topic-0,is_internal=false,partitions=[{error_code=0,partition_index=0,leader_id=0,leader_epoch=0,replica_nodes=[0],isr_nodes=[0],offline_replicas=[]}],topic_authorized_operations=0}],cluster_authorized_operations=0}
2020-04-24 15:28:43,399 DEBUG [o.a.k.c.Metadata] [tcgd-akka.kafka.default-dispatcher-61] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Updated cluster metadata updateVersion 39 to MetadataCache{clusterId='CR-fk2KUTk-knBM_rwsdXg', nodes=[kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)], partitions=[PartitionInfoAndEpoch{partitionInfo=Partition(topic = increasing-topic-0, partition = 0, leader = 0, replicas = [0], isr = [0], offlineReplicas = []), epoch=-1}], controller=kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)}
2020-04-24 15:32:43,515 TRACE [o.a.k.c.n.Selector] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] About to close the idle connection from 2147483647 due to being idle for 540094 millis
2020-04-24 15:32:43,515 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-49] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Node 2147483647 disconnected.
2020-04-24 15:32:43,603 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-60] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Found least loaded node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) connected with no in-flight requests
2020-04-24 15:32:43,603 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-60] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Sending metadata request MetadataRequestData(topics=[MetadataRequestTopic(name='increasing-topic-0')], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)
2020-04-24 15:32:43,603 DEBUG [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-60] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Using older server API v8 to send METADATA {topics=[{name=increasing-topic-0}],allow_auto_topic_creation=true,include_cluster_authorized_operations=false,include_topic_authorized_operations=false} with correlation id 2345 to node 0
2020-04-24 15:32:43,610 TRACE [o.a.k.c.NetworkClient] [tcgd-akka.kafka.default-dispatcher-60] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Completed receive from node 0 for METADATA with correlation id 2345, received {throttle_time_ms=0,brokers=[{node_id=0,host=kafka-a-0.kafka.default.svc.cluster.local,port=9092,rack=null}],cluster_id=CR-fk2KUTk-knBM_rwsdXg,controller_id=0,topics=[{error_code=0,name=increasing-topic-0,is_internal=false,partitions=[{error_code=0,partition_index=0,leader_id=0,leader_epoch=0,replica_nodes=[0],isr_nodes=[0],offline_replicas=[]}],topic_authorized_operations=0}],cluster_authorized_operations=0}
2020-04-24 15:32:43,612 DEBUG [o.a.k.c.Metadata] [tcgd-akka.kafka.default-dispatcher-60] [NO_DOMAIN] [none] [] - [Consumer clientId=consumer-tfp-9-6, groupId=tfp-9] Updated cluster metadata updateVersion 40 to MetadataCache{clusterId='CR-fk2KUTk-knBM_rwsdXg', nodes=[kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)], partitions=[PartitionInfoAndEpoch{partitionInfo=Partition(topic = increasing-topic-0, partition = 0, leader = 0, replicas = [0], isr = [0], offlineReplicas = []), epoch=-1}], controller=kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)}
2020-04-24 15:33:42,496 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Found least loaded node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null) connected with no in-flight requests
2020-04-24 15:33:42,496 DEBUG [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Sending metadata request MetadataRequestData(topics=[], allowAutoTopicCreation=true, includeClusterAuthorizedOperations=false, includeTopicAuthorizedOperations=false) to node kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)
2020-04-24 15:33:42,496 DEBUG [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Using older server API v8 to send METADATA {topics=[],allow_auto_topic_creation=true,include_cluster_authorized_operations=false,include_topic_authorized_operations=false} with correlation id 2336 to node 0
2020-04-24 15:33:42,524 TRACE [o.a.k.c.NetworkClient] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Completed receive from node 0 for METADATA with correlation id 2336, received {throttle_time_ms=0,brokers=[{node_id=0,host=kafka-a-0.kafka.default.svc.cluster.local,port=9092,rack=null}],cluster_id=CR-fk2KUTk-knBM_rwsdXg,controller_id=0,topics=[],cluster_authorized_operations=0}
2020-04-24 15:33:42,524 DEBUG [o.a.k.c.Metadata] [kafka-producer-network-thread | producer-6] [NO_DOMAIN] [none] [] - [Producer clientId=producer-6] Updated cluster metadata updateVersion 20 to MetadataCache{clusterId='CR-fk2KUTk-knBM_rwsdXg', nodes=[kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)], partitions=[], controller=kafka-a-0.kafka.default.svc.cluster.local:9092 (id: 0 rack: null)}