Brokers Not Randomly Selected for Metadata Refresh #1309
Description
Description
When I create a producer and run it (even for a very long time such as an hour) - the same 2 out of 5 total brokers are always selected for a metadata refresh. Is this really random? Also only these two brokers kafkabk2, kafkabk4 are connected at startup.
How to reproduce
-
Set Refresh interval to the minimum value (10000 ms in this case).
-
Wait some time.
-
Observe that the same subset of brokers is selected for metadata refresh (same 2 out of 5 in my case), and also that only these two brokers are connected to at startup.
Checklist
Please provide the following information:
- A complete (i.e. we can run it), minimal program demonstrating the problem. No need to supply a project file.
- Confluent.Kafka nuget version.
v1.3.0 - Apache Kafka version.
kafka_2.12-2.3.0 - Client configuration.
Nothing special other than refresh intervals set to minimum (10,000 ms). - Operating system.
Windows OS \ Azure - Provide logs (with "debug" : "..." as necessary in configuration).
Please see below. - Provide broker log excerpts.
- Critical issue.
[17:48:01 Debug] name: "producer-v1.0.0#producer-1", facility: "WAKEUPFD", level: Debug, message: "[thrd:app]: kafkabk0.something.com:9092/bootstrap: Enabled low-latency ops queue wake-ups"
[17:48:01 Debug] name: "producer-v1.0.0#producer-1", facility: "BRKMAIN", level: Debug, message: "[thrd::0/internal]: :0/internal: Enter main broker thread"
[17:48:01 Debug] name: "producer-v1.0.0#producer-1", facility: "BROKER", level: Debug, message: "[thrd:app]: kafkabk0.something.com:9092/bootstrap: Added new broker with NodeId -1"
[17:48:01 Debug] name: "producer-v1.0.0#producer-1", facility: "WAKEUPFD", level: Debug, message: "[thrd:app]: kafkabk1.something.com:9092/bootstrap: Enabled low-latency ops queue wake-ups"
[17:48:01 Debug] name: "producer-v1.0.0#producer-1", facility: "BRKMAIN", level: Debug, message: "[thrd:kafkabk0.something.com:9092/boots]: kafkabk0.something.com:9092/bootstrap: Enter main broker thread"
[17:48:01 Debug] name: "producer-v1.0.0#producer-1", facility: "BROKER", level: Debug, message: "[thrd:app]: kafkabk1.something.com:9092/bootstrap: Added new broker with NodeId -1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "WAKEUPFD", level: Debug, message: "[thrd:app]: kafkabk2.something.com:9092/bootstrap: Enabled low-latency ops queue wake-ups"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "BRKMAIN", level: Debug, message: "[thrd:kafkabk1.something.com:9092/boots]: kafkabk1.something.com:9092/bootstrap: Enter main broker thread"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "BROKER", level: Debug, message: "[thrd:app]: kafkabk2.something.com:9092/bootstrap: Added new broker with NodeId -1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "WAKEUPFD", level: Debug, message: "[thrd:app]: kafkabk3.something.com:9092/bootstrap: Enabled low-latency ops queue wake-ups"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "BRKMAIN", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Enter main broker thread"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "BROKER", level: Debug, message: "[thrd:app]: kafkabk3.something.com:9092/bootstrap: Added new broker with NodeId -1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "WAKEUPFD", level: Debug, message: "[thrd:app]: kafkabk4.something.com:9092/bootstrap: Enabled low-latency ops queue wake-ups"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "BRKMAIN", level: Debug, message: "[thrd:kafkabk3.something.com:9092/boots]: kafkabk3.something.com:9092/bootstrap: Enter main broker thread"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "BROKER", level: Debug, message: "[thrd:app]: kafkabk4.something.com:9092/bootstrap: Added new broker with NodeId -1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:app]: kafkabk2.something.com:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s))"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "BRKMAIN", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Enter main broker thread"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "INIT", level: Debug, message: "[thrd:app]: librdkafka v1.3.0 (0x10300ff) producer-v1.0.0#producer-1 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, SSL ZLIB SNAPPY SASL_SCRAM PLUGINS HDRHISTOGRAM, debug 0xfffff)"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Received CONNECT op"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: Broadcasting state change"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: broker in state TRY_CONNECT connecting"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: Broadcasting state change"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Connecting to ipv4#0.0.0.2:9092 (plaintext) with socket 1608"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Connected to ipv4#0.0.0.2:9092"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECTED", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Connected (#1)"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "FEATURE", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: Broadcasting state change"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Sent ApiVersionRequest (v0, 46 bytes @ 0, CorrId 1)"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Received ApiVersionResponse (v0, 276 bytes, CorrId 1, rtt 69.31ms)"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Broker API support:"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey Produce (0) Versions 0..7"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey Fetch (1) Versions 0..11"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey Offset (2) Versions 0..5"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey Metadata (3) Versions 0..8"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey LeaderAndIsr (4) Versions 0..2"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey StopReplica (5) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey UpdateMetadata (6) Versions 0..5"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey ControlledShutdown (7) Versions 0..2"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey OffsetCommit (8) Versions 0..7"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey OffsetFetch (9) Versions 0..5"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey FindCoordinator (10) Versions 0..2"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey JoinGroup (11) Versions 0..5"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey Heartbeat (12) Versions 0..3"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey LeaveGroup (13) Versions 0..2"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey SyncGroup (14) Versions 0..3"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey DescribeGroups (15) Versions 0..3"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey ListGroups (16) Versions 0..2"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey SaslHandshake (17) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey ApiVersion (18) Versions 0..2"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey CreateTopics (19) Versions 0..3"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey DeleteTopics (20) Versions 0..3"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey DeleteRecords (21) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey InitProducerId (22) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey OffsetForLeaderEpoch (23) Versions 0..3"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey AddPartitionsToTxn (24) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey AddOffsetsToTxn (25) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey EndTxn (26) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey WriteTxnMarkers (27) Versions 0..0"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey TxnOffsetCommit (28) Versions 0..2"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey DescribeAcls (29) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey CreateAcls (30) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey DeleteAcls (31) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey DescribeConfigs (32) Versions 0..2"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey AlterConfigs (33) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey AlterReplicaLogDirs (34) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey DescribeLogDirs (35) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey SaslAuthenticate (36) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey CreatePartitions (37) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey CreateDelegationToken (38) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey RenewDelegationToken (39) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey ExpireDelegationToken (40) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey DescribeDelegationToken (41) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey DeleteGroups (42) Versions 0..1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey Unknown-43? (43) Versions 0..0"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: ApiKey Unknown-44? (44) Versions 0..0"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature MsgVer1: Produce (2..2) supported by broker"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature MsgVer1: Fetch (2..2) supported by broker"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Enabling feature MsgVer1"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature MsgVer2: Produce (3..3) supported by broker"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature MsgVer2: Fetch (4..4) supported by broker"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Enabling feature MsgVer2"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature ApiVersion: ApiVersion (0..0) supported by broker"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Enabling feature ApiVersion"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Enabling feature BrokerGroupCoordinator"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker"
[17:48:02 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Enabling feature BrokerBalancedConsumer"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature ThrottleTime: Produce (1..2) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature ThrottleTime: Fetch (1..2) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Enabling feature ThrottleTime"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature Sasl: JoinGroup (0..0) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Enabling feature Sasl"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature SaslHandshake: SaslHandshake (0..0) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Enabling feature SaslHandshake"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature LZ4: FindCoordinator (0..0) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Enabling feature LZ4"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature OffsetTime: Offset (1..1) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Enabling feature OffsetTime"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature IdempotentProducer: InitProducerId (0..0) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Enabling feature IdempotentProducer"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature ZSTD: Produce (7..7) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature ZSTD: Fetch (10..10) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Enabling feature ZSTD"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature UnitTest: SaslHandshake (1..1) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Feature UnitTest: SaslAuthenticate (0..0) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Enabling feature UnitTest"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "FEATURE", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,UnitTest"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: Broadcasting state change"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Request metadata for brokers only: connected"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 0 connection attempt(s))"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 2)"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Received CONNECT op"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: Broadcasting state change"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: broker in state TRY_CONNECT connecting"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: Received MetadataResponse (v2, 356 bytes, CorrId 2, rtt 50.03ms)"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/bootstrap: ===== Received metadata: connected ====="
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: Broadcasting state change"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/bootstrap: ClusterId: 1RQ5w_URTpqwUdb-Mgml_Q, ControllerId: 2"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/bootstrap: 5 brokers, 0 topics"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/bootstrap: Broker #0/5: kafkabk0.something.com:9092 NodeId 0"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/bootstrap: Broker #1/5: kafkabk1.something.com:9092 NodeId 1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "UPDATE", level: Debug, message: "[thrd:kafkabk0.something.com:9092/boots]: kafkabk0.something.com:9092/bootstrap: NodeId changed from -1 to 0"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "UPDATE", level: Debug, message: "[thrd:kafkabk0.something.com:9092/boots]: kafkabk0.something.com:9092/0: Name changed from kafkabk0.something.com:9092/bootstrap to kafkabk0.something.com:9092/0"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "LEADER", level: Debug, message: "[thrd:kafkabk0.something.com:9092/boots]: kafkabk0.something.com:9092/0: Mapped 0 partition(s) to broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/bootstrap: Broker #2/5: kafkabk4.something.com:9092 NodeId 4"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "UPDATE", level: Debug, message: "[thrd:kafkabk1.something.com:9092/boots]: kafkabk1.something.com:9092/bootstrap: NodeId changed from -1 to 1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk0.something.com:9092/boots]: Broadcasting state change"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "UPDATE", level: Debug, message: "[thrd:kafkabk1.something.com:9092/boots]: kafkabk1.something.com:9092/1: Name changed from kafkabk1.something.com:9092/bootstrap to kafkabk1.something.com:9092/1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "LEADER", level: Debug, message: "[thrd:kafkabk1.something.com:9092/boots]: kafkabk1.something.com:9092/1: Mapped 0 partition(s) to broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/bootstrap: Broker #3/5: kafkabk2.something.com:9092 NodeId 2"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Connecting to ipv4#0.0.0.4:9092 (plaintext) with socket 2400"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk1.something.com:9092/boots]: Broadcasting state change"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "UPDATE", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/bootstrap: NodeId changed from -1 to 2"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/bootstrap: Broker #4/5: kafkabk3.something.com:9092 NodeId 3"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "UPDATE", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/2: Name changed from kafkabk2.something.com:9092/bootstrap to kafkabk2.something.com:9092/2"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "LEADER", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/2: Mapped 0 partition(s) to broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/2: Broker changed state UP -> UPDATE"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "UPDATE", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: NodeId changed from -1 to 4"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: Broadcasting state change"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "UPDATE", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Name changed from kafkabk4.something.com:9092/bootstrap to kafkabk4.something.com:9092/4"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: Broadcasting state change"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "LEADER", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Mapped 0 partition(s) to broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "CLUSTERID", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: ClusterId update "" -> "1RQ5w_URTpqwUdb-Mgml_Q""
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/2: Broker changed state UPDATE -> UP"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: Broadcasting state change"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "CONTROLLERID", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: ControllerId update -1 -> 2"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: Broadcasting state change"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Connected to ipv4#0.0.0.4:9092"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:main]: Broadcasting state change"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "UPDATE", level: Debug, message: "[thrd:kafkabk3.something.com:9092/boots]: kafkabk3.something.com:9092/bootstrap: NodeId changed from -1 to 3"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECTED", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Connected (#1)"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "UPDATE", level: Debug, message: "[thrd:kafkabk3.something.com:9092/boots]: kafkabk3.something.com:9092/3: Name changed from kafkabk3.something.com:9092/bootstrap to kafkabk3.something.com:9092/3"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "FEATURE", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Updated enabled protocol features +ApiVersion to ApiVersion"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "LEADER", level: Debug, message: "[thrd:kafkabk3.something.com:9092/boots]: kafkabk3.something.com:9092/3: Mapped 0 partition(s) to broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Broker changed state CONNECT -> APIVERSION_QUERY"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk3.something.com:9092/boots]: Broadcasting state change"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: Broadcasting state change"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Sent ApiVersionRequest (v0, 46 bytes @ 0, CorrId 1)"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Received ApiVersionResponse (v0, 276 bytes, CorrId 1, rtt 50.41ms)"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Broker API support:"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey Produce (0) Versions 0..7"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey Fetch (1) Versions 0..11"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey Offset (2) Versions 0..5"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey Metadata (3) Versions 0..8"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey LeaderAndIsr (4) Versions 0..2"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey StopReplica (5) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey UpdateMetadata (6) Versions 0..5"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey ControlledShutdown (7) Versions 0..2"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey OffsetCommit (8) Versions 0..7"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey OffsetFetch (9) Versions 0..5"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey FindCoordinator (10) Versions 0..2"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey JoinGroup (11) Versions 0..5"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey Heartbeat (12) Versions 0..3"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey LeaveGroup (13) Versions 0..2"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey SyncGroup (14) Versions 0..3"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey DescribeGroups (15) Versions 0..3"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey ListGroups (16) Versions 0..2"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey SaslHandshake (17) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey ApiVersion (18) Versions 0..2"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey CreateTopics (19) Versions 0..3"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey DeleteTopics (20) Versions 0..3"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey DeleteRecords (21) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey InitProducerId (22) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey OffsetForLeaderEpoch (23) Versions 0..3"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey AddPartitionsToTxn (24) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey AddOffsetsToTxn (25) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey EndTxn (26) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey WriteTxnMarkers (27) Versions 0..0"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey TxnOffsetCommit (28) Versions 0..2"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey DescribeAcls (29) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey CreateAcls (30) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey DeleteAcls (31) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey DescribeConfigs (32) Versions 0..2"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey AlterConfigs (33) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey AlterReplicaLogDirs (34) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey DescribeLogDirs (35) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey SaslAuthenticate (36) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey CreatePartitions (37) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey CreateDelegationToken (38) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey RenewDelegationToken (39) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey ExpireDelegationToken (40) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey DescribeDelegationToken (41) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey DeleteGroups (42) Versions 0..1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey Unknown-43? (43) Versions 0..0"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: ApiKey Unknown-44? (44) Versions 0..0"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature MsgVer1: Produce (2..2) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature MsgVer1: Fetch (2..2) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Enabling feature MsgVer1"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature MsgVer2: Produce (3..3) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature MsgVer2: Fetch (4..4) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Enabling feature MsgVer2"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature ApiVersion: ApiVersion (0..0) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Enabling feature ApiVersion"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Enabling feature BrokerGroupCoordinator"
[17:48:03 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Enabling feature BrokerBalancedConsumer"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature ThrottleTime: Produce (1..2) supported by broker"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature ThrottleTime: Fetch (1..2) supported by broker"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Enabling feature ThrottleTime"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature Sasl: JoinGroup (0..0) supported by broker"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Enabling feature Sasl"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature SaslHandshake: SaslHandshake (0..0) supported by broker"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Enabling feature SaslHandshake"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature LZ4: FindCoordinator (0..0) supported by broker"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Enabling feature LZ4"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature OffsetTime: Offset (1..1) supported by broker"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Enabling feature OffsetTime"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature IdempotentProducer: InitProducerId (0..0) supported by broker"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Enabling feature IdempotentProducer"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature ZSTD: Produce (7..7) supported by broker"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature ZSTD: Fetch (10..10) supported by broker"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Enabling feature ZSTD"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature UnitTest: SaslHandshake (1..1) supported by broker"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Feature UnitTest: SaslAuthenticate (0..0) supported by broker"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Enabling feature UnitTest"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "FEATURE", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,UnitTest"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Broker changed state APIVERSION_QUERY -> UP"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: Broadcasting state change"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Request metadata for brokers only: connected"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 2)"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Received MetadataResponse (v2, 356 bytes, CorrId 2, rtt 50.70ms)"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: ===== Received metadata: connected ====="
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: ClusterId: 1RQ5w_URTpqwUdb-Mgml_Q, ControllerId: 2"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: 5 brokers, 0 topics"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #0/5: kafkabk0.something.com:9092 NodeId 0"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #1/5: kafkabk1.something.com:9092 NodeId 1"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #2/5: kafkabk4.something.com:9092 NodeId 4"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #3/5: kafkabk2.something.com:9092 NodeId 2"
[17:48:04 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #4/5: kafkabk3.something.com:9092 NodeId 3"
[17:48:11 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Request metadata for brokers only: periodic broker list refresh"
[17:48:11 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/2: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 3)"
[17:48:11 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/2: Received MetadataResponse (v2, 356 bytes, CorrId 3, rtt 51.18ms)"
[17:48:11 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: ===== Received metadata: periodic broker list refresh ====="
[17:48:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: ClusterId: 1RQ5w_URTpqwUdb-Mgml_Q, ControllerId: 2"
[17:48:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: 5 brokers, 0 topics"
[17:48:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #0/5: kafkabk0.something.com:9092 NodeId 0"
[17:48:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #1/5: kafkabk1.something.com:9092 NodeId 1"
[17:48:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #2/5: kafkabk4.something.com:9092 NodeId 4"
[17:48:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #3/5: kafkabk2.something.com:9092 NodeId 2"
[17:48:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #4/5: kafkabk3.something.com:9092 NodeId 3"
[17:48:21 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Request metadata for brokers only: periodic broker list refresh"
[17:48:21 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 3)"
[17:48:22 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Received MetadataResponse (v2, 356 bytes, CorrId 3, rtt 70.51ms)"
[17:48:22 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: ===== Received metadata: periodic broker list refresh ====="
[17:48:22 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: ClusterId: 1RQ5w_URTpqwUdb-Mgml_Q, ControllerId: 2"
[17:48:22 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: 5 brokers, 0 topics"
[17:48:22 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #0/5: kafkabk0.something.com:9092 NodeId 0"
[17:48:22 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #1/5: kafkabk1.something.com:9092 NodeId 1"
[17:48:22 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #2/5: kafkabk4.something.com:9092 NodeId 4"
[17:48:22 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #3/5: kafkabk2.something.com:9092 NodeId 2"
[17:48:22 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #4/5: kafkabk3.something.com:9092 NodeId 3"
[17:48:31 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Request metadata for brokers only: periodic broker list refresh"
[17:48:31 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/2: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 4)"
[17:48:32 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/2: Received MetadataResponse (v2, 356 bytes, CorrId 4, rtt 64.91ms)"
[17:48:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: ===== Received metadata: periodic broker list refresh ====="
[17:48:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: ClusterId: 1RQ5w_URTpqwUdb-Mgml_Q, ControllerId: 2"
[17:48:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: 5 brokers, 0 topics"
[17:48:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #0/5: kafkabk0.something.com:9092 NodeId 0"
[17:48:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #1/5: kafkabk1.something.com:9092 NodeId 1"
[17:48:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #2/5: kafkabk4.something.com:9092 NodeId 4"
[17:48:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #3/5: kafkabk2.something.com:9092 NodeId 2"
[17:48:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #4/5: kafkabk3.something.com:9092 NodeId 3"
[17:48:41 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Request metadata for brokers only: periodic broker list refresh"
[17:48:41 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/2: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 5)"
[17:48:42 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/2: Received MetadataResponse (v2, 356 bytes, CorrId 5, rtt 49.11ms)"
[17:48:42 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: ===== Received metadata: periodic broker list refresh ====="
[17:48:42 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: ClusterId: 1RQ5w_URTpqwUdb-Mgml_Q, ControllerId: 2"
[17:48:42 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: 5 brokers, 0 topics"
[17:48:42 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #0/5: kafkabk0.something.com:9092 NodeId 0"
[17:48:42 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #1/5: kafkabk1.something.com:9092 NodeId 1"
[17:48:42 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #2/5: kafkabk4.something.com:9092 NodeId 4"
[17:48:42 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #3/5: kafkabk2.something.com:9092 NodeId 2"
[17:48:42 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #4/5: kafkabk3.something.com:9092 NodeId 3"
[17:48:51 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Request metadata for brokers only: periodic broker list refresh"
[17:48:51 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/2: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 6)"
[17:48:52 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/2: Received MetadataResponse (v2, 356 bytes, CorrId 6, rtt 52.36ms)"
[17:48:52 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: ===== Received metadata: periodic broker list refresh ====="
[17:48:52 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: ClusterId: 1RQ5w_URTpqwUdb-Mgml_Q, ControllerId: 2"
[17:48:52 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: 5 brokers, 0 topics"
[17:48:52 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #0/5: kafkabk0.something.com:9092 NodeId 0"
[17:48:52 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #1/5: kafkabk1.something.com:9092 NodeId 1"
[17:48:52 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #2/5: kafkabk4.something.com:9092 NodeId 4"
[17:48:52 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #3/5: kafkabk2.something.com:9092 NodeId 2"
[17:48:52 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #4/5: kafkabk3.something.com:9092 NodeId 3"
[17:49:01 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Request metadata for brokers only: periodic broker list refresh"
[17:49:01 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/2: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 7)"
[17:49:02 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/2: Received MetadataResponse (v2, 356 bytes, CorrId 7, rtt 80.36ms)"
[17:49:02 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: ===== Received metadata: periodic broker list refresh ====="
[17:49:02 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: ClusterId: 1RQ5w_URTpqwUdb-Mgml_Q, ControllerId: 2"
[17:49:02 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: 5 brokers, 0 topics"
[17:49:02 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #0/5: kafkabk0.something.com:9092 NodeId 0"
[17:49:02 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #1/5: kafkabk1.something.com:9092 NodeId 1"
[17:49:02 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #2/5: kafkabk4.something.com:9092 NodeId 4"
[17:49:02 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #3/5: kafkabk2.something.com:9092 NodeId 2"
[17:49:02 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #4/5: kafkabk3.something.com:9092 NodeId 3"
[17:49:11 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Request metadata for brokers only: periodic broker list refresh"
[17:49:11 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/2: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 8)"
[17:49:12 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk2.something.com:9092/boots]: kafkabk2.something.com:9092/2: Received MetadataResponse (v2, 356 bytes, CorrId 8, rtt 50.80ms)"
[17:49:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: ===== Received metadata: periodic broker list refresh ====="
[17:49:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: ClusterId: 1RQ5w_URTpqwUdb-Mgml_Q, ControllerId: 2"
[17:49:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: 5 brokers, 0 topics"
[17:49:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #0/5: kafkabk0.something.com:9092 NodeId 0"
[17:49:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #1/5: kafkabk1.something.com:9092 NodeId 1"
[17:49:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #2/5: kafkabk4.something.com:9092 NodeId 4"
[17:49:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #3/5: kafkabk2.something.com:9092 NodeId 2"
[17:49:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com:9092/2: Broker #4/5: kafkabk3.something.com:9092 NodeId 3"
[17:49:21 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Request metadata for brokers only: periodic broker list refresh"
[17:49:22 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 4)"
[17:49:22 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Received MetadataResponse (v2, 356 bytes, CorrId 4, rtt 60.15ms)"
[17:49:22 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: ===== Received metadata: periodic broker list refresh ====="
[17:49:22 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: ClusterId: 1RQ5w_URTpqwUdb-Mgml_Q, ControllerId: 2"
[17:49:22 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: 5 brokers, 0 topics"
[17:49:22 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #0/5: kafkabk0.something.com:9092 NodeId 0"
[17:49:22 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #1/5: kafkabk1.something.com:9092 NodeId 1"
[17:49:22 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #2/5: kafkabk4.something.com:9092 NodeId 4"
[17:49:22 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #3/5: kafkabk2.something.com:9092 NodeId 2"
[17:49:22 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #4/5: kafkabk3.something.com:9092 NodeId 3"
[17:49:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Request metadata for brokers only: periodic broker list refresh"
[17:49:32 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 5)"
[17:49:32 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Received MetadataResponse (v2, 356 bytes, CorrId 5, rtt 56.28ms)"
[17:49:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: ===== Received metadata: periodic broker list refresh ====="
[17:49:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: ClusterId: 1RQ5w_URTpqwUdb-Mgml_Q, ControllerId: 2"
[17:49:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: 5 brokers, 0 topics"
[17:49:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #0/5: kafkabk0.something.com:9092 NodeId 0"
[17:49:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #1/5: kafkabk1.something.com:9092 NodeId 1"
[17:49:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #2/5: kafkabk4.something.com:9092 NodeId 4"
[17:49:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #3/5: kafkabk2.something.com:9092 NodeId 2"
[17:49:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #4/5: kafkabk3.something.com:9092 NodeId 3"
[17:49:42 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Request metadata for brokers only: periodic broker list refresh"
[17:49:42 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 6)"
[17:49:42 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Received MetadataResponse (v2, 356 bytes, CorrId 6, rtt 62.26ms)"
[17:49:42 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: ===== Received metadata: periodic broker list refresh ====="
[17:49:42 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: ClusterId: 1RQ5w_URTpqwUdb-Mgml_Q, ControllerId: 2"
[17:49:42 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: 5 brokers, 0 topics"
[17:49:42 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #0/5: kafkabk0.something.com:9092 NodeId 0"
[17:49:42 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #1/5: kafkabk1.something.com:9092 NodeId 1"
[17:49:42 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #2/5: kafkabk4.something.com:9092 NodeId 4"
[17:49:42 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #3/5: kafkabk2.something.com:9092 NodeId 2"
[17:49:42 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #4/5: kafkabk3.something.com:9092 NodeId 3"
[17:49:52 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Request metadata for brokers only: periodic broker list refresh"
[17:49:52 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 7)"
[17:49:52 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Received MetadataResponse (v2, 356 bytes, CorrId 7, rtt 53.75ms)"
[17:49:52 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: ===== Received metadata: periodic broker list refresh ====="
[17:49:52 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: ClusterId: 1RQ5w_URTpqwUdb-Mgml_Q, ControllerId: 2"
[17:49:52 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: 5 brokers, 0 topics"
[17:49:52 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #0/5: kafkabk0.something.com:9092 NodeId 0"
[17:49:52 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #1/5: kafkabk1.something.com:9092 NodeId 1"
[17:49:52 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #2/5: kafkabk4.something.com:9092 NodeId 4"
[17:49:52 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #3/5: kafkabk2.something.com:9092 NodeId 2"
[17:49:52 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #4/5: kafkabk3.something.com:9092 NodeId 3"
[17:50:02 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Request metadata for brokers only: periodic broker list refresh"
[17:50:02 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 8)"
[17:50:02 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Received MetadataResponse (v2, 356 bytes, CorrId 8, rtt 51.33ms)"
[17:50:02 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: ===== Received metadata: periodic broker list refresh ====="
[17:50:02 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: ClusterId: 1RQ5w_URTpqwUdb-Mgml_Q, ControllerId: 2"
[17:50:02 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: 5 brokers, 0 topics"
[17:50:02 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #0/5: kafkabk0.something.com:9092 NodeId 0"
[17:50:02 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #1/5: kafkabk1.something.com:9092 NodeId 1"
[17:50:02 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #2/5: kafkabk4.something.com:9092 NodeId 4"
[17:50:02 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #3/5: kafkabk2.something.com:9092 NodeId 2"
[17:50:02 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #4/5: kafkabk3.something.com:9092 NodeId 3"
[17:50:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Request metadata for brokers only: periodic broker list refresh"
[17:50:12 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 9)"
[17:50:12 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Received MetadataResponse (v2, 356 bytes, CorrId 9, rtt 57.43ms)"
[17:50:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: ===== Received metadata: periodic broker list refresh ====="
[17:50:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: ClusterId: 1RQ5w_URTpqwUdb-Mgml_Q, ControllerId: 2"
[17:50:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: 5 brokers, 0 topics"
[17:50:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #0/5: kafkabk0.something.com:9092 NodeId 0"
[17:50:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #1/5: kafkabk1.something.com:9092 NodeId 1"
[17:50:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #2/5: kafkabk4.something.com:9092 NodeId 4"
[17:50:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #3/5: kafkabk2.something.com:9092 NodeId 2"
[17:50:12 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker #4/5: kafkabk3.something.com:9092 NodeId 3"