Producer Metadata Refresh on Disconnected Broker Takes 20 seconds to Fail #1305
Description
Description
-
When topic metadata is requested from a broker that has disconnected (presumably due to the connection being idle) - the request takes 20 seconds to fail. I would think this would be sub-second failure?
-
This is having a large impact for us at night when throughput is lowest - we have many instances of our microservice - but at night most of the producers are idle - too often we are getting 10 second or 20 second delays when it should be 60 ms to produce.
How to reproduce
-
Create a producer and point it at a kafka with several brokers (5 in my case).
-
Default TopicMetadataRefreshIntervalMs == 300000 ms.
-
At some point the producer will request metadata from a broker that has disconnected.
-
It will take 20 seconds to fail, and then an additional second or two to reconnect and sync back up.
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
1.3.0 -
Apache Kafka version.
kafka_2.12-2.3.0 -
Client configuration.
bootstrap.servers="kafkabk0.something.com:9092,kafkabk1.something.com:9092,kafkabk2.something.com:9092,kafkabk3.something.com:9092,kafkabk4.something.com:9092" -
Operating system.
Windows. -
Provide logs (with "debug" : "..." as necessary in configuration).
[15:07:30 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"
[15:07:30 Debug] name: "producer-v1.0.0#producer-1", facility: "BRKMAIN", level: Debug, message: "[thrd::0/internal]: :0/internal: Enter main broker thread"
[15:07:30 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"
[15:07:30 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"
[15:07:30 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"
[15:07:30 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"
[15:07:30 Debug] name: "producer-v1.0.0#producer-1", facility: "WAKEUPFD", level: Debug, message: "[thrd:app]: kafkabk2.something.com9092/bootstrap: Enabled low-latency ops queue wake-ups"
[15:07:30 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"
[15:07:30 Debug] name: "producer-v1.0.0#producer-1", facility: "BROKER", level: Debug, message: "[thrd:app]: kafkabk2.something.com9092/bootstrap: Added new broker with NodeId -1"
[15:07:30 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"
[15:07:30 Debug] name: "producer-v1.0.0#producer-1", facility: "BRKMAIN", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Enter main broker thread"
[15:07:30 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"
[15:07:30 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"
[15:07:30 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"
[15:07:30 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"
[15:07:30 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:app]: kafkabk2.something.com9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s))"
[15:07:30 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"
[15:07:30 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)"
[15:07:30 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Received CONNECT op"
[15:07:30 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Broker changed state INIT -> TRY_CONNECT"
[15:07:30 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: Broadcasting state change"
[15:07:30 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: broker in state TRY_CONNECT connecting"
[15:07:30 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT"
[15:07:30 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: Broadcasting state change"
[15:07:30 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Connecting to ipv4#0.0.0.2:9092 (plaintext) with socket 2308"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Connected to ipv4#0.0.0.2:9092"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECTED", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Connected (RdKafka -> Confluent.Kafka #1)"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "FEATURE", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: Broadcasting state change"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Sent ApiVersionRequest (v0, 46 bytes @ 0, CorrId 1)"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Received ApiVersionResponse (v0, 276 bytes, CorrId 1, rtt 64.11ms)"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Broker API support:"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey Produce (0) Versions 0..7"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey Fetch (1) Versions 0..11"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey Offset (2) Versions 0..5"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey Metadata (3) Versions 0..8"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey LeaderAndIsr (4) Versions 0..2"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey StopReplica (5) Versions 0..1"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey UpdateMetadata (6) Versions 0..5"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey ControlledShutdown (7) Versions 0..2"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey OffsetCommit (8) Versions 0..7"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey OffsetFetch (9) Versions 0..5"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey FindCoordinator (10) Versions 0..2"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey JoinGroup (11) Versions 0..5"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey Heartbeat (12) Versions 0..3"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey LeaveGroup (13) Versions 0..2"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey SyncGroup (14) Versions 0..3"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey DescribeGroups (15) Versions 0..3"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey ListGroups (16) Versions 0..2"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey SaslHandshake (17) Versions 0..1"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey ApiVersion (18) Versions 0..2"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey CreateTopics (19) Versions 0..3"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey DeleteTopics (20) Versions 0..3"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey DeleteRecords (21) Versions 0..1"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey InitProducerId (22) Versions 0..1"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey OffsetForLeaderEpoch (23) Versions 0..3"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey AddPartitionsToTxn (24) Versions 0..1"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey AddOffsetsToTxn (25) Versions 0..1"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey EndTxn (26) Versions 0..1"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey WriteTxnMarkers (27) Versions 0..0"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey TxnOffsetCommit (28) Versions 0..2"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey DescribeAcls (29) Versions 0..1"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey CreateAcls (30) Versions 0..1"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey DeleteAcls (31) Versions 0..1"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey DescribeConfigs (32) Versions 0..2"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey AlterConfigs (33) Versions 0..1"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey AlterReplicaLogDirs (34) Versions 0..1"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey DescribeLogDirs (35) Versions 0..1"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey SaslAuthenticate (36) Versions 0..1"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey CreatePartitions (37) Versions 0..1"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey CreateDelegationToken (38) Versions 0..1"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey RenewDelegationToken (39) Versions 0..1"
[15:07:31 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))"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey ExpireDelegationToken (40) Versions 0..1"
[15:07:31 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"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey DescribeDelegationToken (41) Versions 0..1"
[15:07:31 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"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey DeleteGroups (42) Versions 0..1"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: Broadcasting state change"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey Unknown-43? (43) Versions 0..0"
[15:07:31 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"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: ApiKey Unknown-44? (44) Versions 0..0"
[15:07:31 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"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature MsgVer1: Produce (2..2) supported by broker"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature MsgVer1: Fetch (2..2) supported by broker"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Enabling feature MsgVer1"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: Broadcasting state change"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature MsgVer2: Produce (3..3) supported by broker"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature MsgVer2: Fetch (4..4) supported by broker"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Enabling feature MsgVer2"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature ApiVersion: ApiVersion (0..0) supported by broker"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Enabling feature ApiVersion"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Enabling feature BrokerGroupCoordinator"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Enabling feature BrokerBalancedConsumer"
[15:07:31 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 2360"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature ThrottleTime: Produce (1..2) supported by broker"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature ThrottleTime: Fetch (1..2) supported by broker"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Enabling feature ThrottleTime"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature Sasl: JoinGroup (0..0) supported by broker"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Enabling feature Sasl"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature SaslHandshake: SaslHandshake (0..0) supported by broker"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Enabling feature SaslHandshake"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature LZ4: FindCoordinator (0..0) supported by broker"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Enabling feature LZ4"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Connected to ipv4#0.0.0.4:9092"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature OffsetTime: Offset (1..1) supported by broker"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECTED", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Connected (RdKafka -> Confluent.Kafka #1)"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Enabling feature OffsetTime"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "FEATURE", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature IdempotentProducer: InitProducerId (0..0) supported by broker"
[15:07:31 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 CONNECT -> APIVERSION_QUERY"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: Broadcasting state change"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Enabling feature IdempotentProducer"
[15:07:31 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Sent ApiVersionRequest (v0, 46 bytes @ 0, CorrId 1)"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature ZSTD: Produce (7..7) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature ZSTD: Fetch (10..10) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Enabling feature ZSTD"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature UnitTest: SaslHandshake (1..1) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Feature UnitTest: SaslAuthenticate (0..0) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Enabling feature UnitTest"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "FEATURE", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,UnitTest"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Received ApiVersionResponse (v0, 276 bytes, CorrId 1, rtt 64.37ms)"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: Broadcasting state change"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Broker API support:"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Request metadata for brokers only: connected"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey Produce (0) Versions 0..7"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 2)"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey Fetch (1) Versions 0..11"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey Offset (2) Versions 0..5"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey Metadata (3) Versions 0..8"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey LeaderAndIsr (4) Versions 0..2"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey StopReplica (5) Versions 0..1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey UpdateMetadata (6) Versions 0..5"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey ControlledShutdown (7) Versions 0..2"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: Received MetadataResponse (v2, 356 bytes, CorrId 2, rtt 62.86ms)"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey OffsetCommit (8) Versions 0..7"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/bootstrap: ===== Received metadata: connected ====="
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey OffsetFetch (9) Versions 0..5"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/bootstrap: ClusterId: 1RQ5w_URTpqwUdb-Mgml_Q, ControllerId: 2"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey FindCoordinator (10) Versions 0..2"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/bootstrap: 5 brokers, 0 topics"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey JoinGroup (11) Versions 0..5"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/bootstrap: Broker #0/5: kafkabk0.something.com:9092 NodeId 0"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey Heartbeat (12) Versions 0..3"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/bootstrap: Broker RdKafka -> Confluent.Kafka #1/5: kafkabk4.something.com:9092 NodeId 4"
[15:07:32 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"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey LeaveGroup (13) Versions 0..2"
[15:07:32 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"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey SyncGroup (14) Versions 0..3"
[15:07:32 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"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/bootstrap: Broker RdKafka -> Confluent.Kafka #2/5: kafkabk1.something.com:9092 NodeId 1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey DescribeGroups (15) Versions 0..3"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey ListGroups (16) Versions 0..2"
[15:07:32 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"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/bootstrap: Broker Config as IEnumerable<KeyValuePair<string,string>> #3/5: kafkabk2.something.com9092 NodeId 2"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk0.something.com:9092/boots]: Broadcasting state change"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey SaslHandshake (17) Versions 0..1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey ApiVersion (18) Versions 0..2"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey CreateTopics (19) Versions 0..3"
[15:07:32 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"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey DeleteTopics (20) Versions 0..3"
[15:07:32 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"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/bootstrap: Broker Producer refactor #4/5: kafkabk3.something.com:9092 NodeId 3"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "UPDATE", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/bootstrap: NodeId changed from -1 to 2"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey DeleteRecords (21) Versions 0..1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk1.something.com:9092/boots]: Broadcasting state change"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "UPDATE", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Name changed from kafkabk2.something.com9092/bootstrap to kafkabk2.something.com9092/2"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey InitProducerId (22) Versions 0..1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey OffsetForLeaderEpoch (23) Versions 0..3"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "CLUSTERID", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: ClusterId update "" -> "1RQ5w_URTpqwUdb-Mgml_Q""
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "LEADER", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Mapped 0 partition(s) to broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Broker changed state UP -> UPDATE"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "CONTROLLERID", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: ControllerId update -1 -> 2"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey AddPartitionsToTxn (24) Versions 0..1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: Broadcasting state change"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: Broadcasting state change"
[15:07:32 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"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey AddOffsetsToTxn (25) Versions 0..1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:main]: Broadcasting state change"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Broker changed state UPDATE -> UP"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: Broadcasting state change"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey EndTxn (26) Versions 0..1"
[15:07:32 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"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey WriteTxnMarkers (27) Versions 0..0"
[15:07:32 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"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey TxnOffsetCommit (28) Versions 0..2"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk3.something.com:9092/boots]: Broadcasting state change"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey DescribeAcls (29) Versions 0..1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey CreateAcls (30) Versions 0..1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey DeleteAcls (31) Versions 0..1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey DescribeConfigs (32) Versions 0..2"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey AlterConfigs (33) Versions 0..1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey AlterReplicaLogDirs (34) Versions 0..1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey DescribeLogDirs (35) Versions 0..1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey SaslAuthenticate (36) Versions 0..1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey CreatePartitions (37) Versions 0..1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey CreateDelegationToken (38) Versions 0..1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey RenewDelegationToken (39) Versions 0..1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey ExpireDelegationToken (40) Versions 0..1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey DescribeDelegationToken (41) Versions 0..1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey DeleteGroups (42) Versions 0..1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey Unknown-43? (43) Versions 0..0"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: ApiKey Unknown-44? (44) Versions 0..0"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature MsgVer1: Produce (2..2) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature MsgVer1: Fetch (2..2) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Enabling feature MsgVer1"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature MsgVer2: Produce (3..3) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature MsgVer2: Fetch (4..4) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Enabling feature MsgVer2"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature ApiVersion: ApiVersion (0..0) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Enabling feature ApiVersion"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Enabling feature BrokerGroupCoordinator"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Enabling feature BrokerBalancedConsumer"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature ThrottleTime: Produce (1..2) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature ThrottleTime: Fetch (1..2) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Enabling feature ThrottleTime"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature Sasl: JoinGroup (0..0) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Enabling feature Sasl"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature SaslHandshake: SaslHandshake (0..0) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Enabling feature SaslHandshake"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature LZ4: FindCoordinator (0..0) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Enabling feature LZ4"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature OffsetTime: Offset (1..1) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Enabling feature OffsetTime"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature IdempotentProducer: InitProducerId (0..0) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Enabling feature IdempotentProducer"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature ZSTD: Produce (7..7) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature ZSTD: Fetch (10..10) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Enabling feature ZSTD"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature UnitTest: SaslHandshake (1..1) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Feature UnitTest: SaslAuthenticate (0..0) supported by broker"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Enabling feature UnitTest"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "FEATURE", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,UnitTest"
[15:07:32 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 APIVERSION_QUERY -> UP"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: Broadcasting state change"
[15:07:32 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/bootstrap: Request metadata for brokers only: connected"
[15:07:32 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"
[15:07:32 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"
[15:07:32 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"
[15:07:32 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 UP -> UPDATE"
[15:07:33 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: Broadcasting state change"
[15:07:33 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: Broadcasting state change"
[15:07:33 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)"
[15:07:33 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 77.07ms)"
[15:07:33 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: ===== Received metadata: connected ====="
[15:07:33 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"
[15:07:33 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: 5 brokers, 0 topics"
[15:07:33 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"
[15:07:33 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker RdKafka -> Confluent.Kafka #1/5: kafkabk4.something.com:9092 NodeId 4"
[15:07:33 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker RdKafka -> Confluent.Kafka #2/5: kafkabk1.something.com:9092 NodeId 1"
[15:07:33 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker Config as IEnumerable<KeyValuePair<string,string>> #3/5: kafkabk2.something.com9092 NodeId 2"
[15:07:33 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker Producer refactor #4/5: kafkabk3.something.com:9092 NodeId 3"
[15:07:34 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 UPDATE -> UP"
[15:07:34 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: Broadcasting state change"
[15:10:20 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: Request metadata for brokers only: periodic broker list refresh"
[15:10:20 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 3)"
[15:10:20 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Received MetadataResponse (v2, 356 bytes, CorrId 3, rtt 65.17ms)"
[15:10:20 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: ===== Received metadata: periodic broker list refresh ====="
[15:10:20 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: ClusterId: 1RQ5w_URTpqwUdb-Mgml_Q, ControllerId: 2"
[15:10:20 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: 5 brokers, 0 topics"
[15:10:20 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: Broker #0/5: kafkabk0.something.com:9092 NodeId 0"
[15:10:20 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: Broker RdKafka -> Confluent.Kafka #1/5: kafkabk4.something.com:9092 NodeId 4"
[15:10:20 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: Broker RdKafka -> Confluent.Kafka #2/5: kafkabk1.something.com:9092 NodeId 1"
[15:10:20 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: Broker Config as IEnumerable<KeyValuePair<string,string>> #3/5: kafkabk2.something.com9092 NodeId 2"
[15:10:20 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: Broker Producer refactor #4/5: kafkabk3.something.com:9092 NodeId 3"
[15:13:10 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"
[15:13:10 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)"
[15:13:29 Debug] name: "producer-v1.0.0#producer-1", facility: "BROKERFAIL", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: failed: err: Local: Broker transport failure: (errno: No error)"
[15:13:29 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 UP -> DOWN"
[15:13:35 Error] Producer error: IsBrokerError: False, IsError: True, IsFatal: False, IsLocalError: True, Code: Local_Transport, reason: "kafkabk4.something.com:9092/4: Disconnected (after 355705ms in state UP)"
[15:13:35 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: Broadcasting state change"
[15:13:35 Debug] name: "producer-v1.0.0#producer-1", facility: "BUFQ", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Purging bufq with 1 buffers"
[15:13:35 Debug] name: "producer-v1.0.0#producer-1", facility: "BUFQ", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Purging bufq with 0 buffers"
[15:13:35 Debug] name: "producer-v1.0.0#producer-1", facility: "REQERR", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: MetadataRequest failed: Local: Broker transport failure: actions Retry"
[15:13:35 Debug] name: "producer-v1.0.0#producer-1", facility: "BUFQ", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Updating 0 buffers on connection reset"
[15:13:35 Debug] name: "producer-v1.0.0#producer-1", facility: "RETRY", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Retrying MetadataRequest (v2, 46 bytes, retry 1/2, prev CorrId 3) in 100ms"
[15:13:35 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 DOWN -> INIT"
[15:13:35 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: Broadcasting state change"
[15:13:36 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 INIT -> TRY_CONNECT"
[15:13:36 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: Broadcasting state change"
[15:13:36 Debug] name: "producer-v1.0.0#producer-1", facility: "RETRY", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Moved 1 retry buffer(s) to output queue"
[15:13:37 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: broker in state TRY_CONNECT connecting"
[15:13:37 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 TRY_CONNECT -> CONNECT"
[15:13:37 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: Broadcasting state change"
[15:13:37 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Connecting to ipv4#0.0.0.4:9092 (plaintext) with socket 2320"
[15:13:37 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"
[15:13:37 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 (RdKafka -> Confluent.Kafka #2)"
[15:13:37 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"
[15:13:37 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: Broadcasting state change"
[15:13:37 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 4)"
[15:13:37 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 4, rtt 65.64ms)"
[15:13:37 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:"
[15:13:37 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"
[15:13:37 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"
[15:13:37 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"
[15:13:37 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 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"
[15:13:38 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: Broadcasting state change"
[15:13:38 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"
[15:13:38 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:kafkabk4.something.com:9092/boots]: kafkabk4.something.com:9092/4: Skipping metadata request: connected: full request already in-transit"
[15:13:38 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)"
[15:13:38 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 63.91ms)"
[15:13:38 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 ====="
[15:13:38 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"
[15:13:38 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: 5 brokers, 0 topics"
[15:13:38 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"
[15:13:38 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker RdKafka -> Confluent.Kafka #1/5: kafkabk4.something.com:9092 NodeId 4"
[15:13:38 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker RdKafka -> Confluent.Kafka #2/5: kafkabk1.something.com:9092 NodeId 1"
[15:13:38 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker Config as IEnumerable<KeyValuePair<string,string>> #3/5: kafkabk2.something.com9092 NodeId 2"
[15:13:38 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk4.something.com:9092/4: Broker Producer refactor #4/5: kafkabk3.something.com:9092 NodeId 3"
[15:16:00 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: Request metadata for brokers only: periodic broker list refresh"
[15:16:00 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 4)"
[15:16:19 Debug] name: "producer-v1.0.0#producer-1", facility: "BROKERFAIL", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: failed: err: Local: Broker transport failure: (errno: No error)"
[15:16:19 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Broker changed state UP -> DOWN"
[15:16:27 Error] Producer error: IsBrokerError: False, IsError: True, IsFatal: False, IsLocalError: True, Code: Local_Transport, reason: "kafkabk2.something.com9092/2: Disconnected (after 527240ms in state UP)"
[15:16:27 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: Broadcasting state change"
[15:16:27 Debug] name: "producer-v1.0.0#producer-1", facility: "BUFQ", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Purging bufq with 1 buffers"
[15:16:27 Debug] name: "producer-v1.0.0#producer-1", facility: "BUFQ", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Purging bufq with 0 buffers"
[15:16:27 Debug] name: "producer-v1.0.0#producer-1", facility: "BUFQ", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Updating 0 buffers on connection reset"
[15:16:27 Debug] name: "producer-v1.0.0#producer-1", facility: "REQERR", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: MetadataRequest failed: Local: Broker transport failure: actions Retry"
[15:16:27 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Broker changed state DOWN -> INIT"
[15:16:27 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: Broadcasting state change"
[15:16:27 Debug] name: "producer-v1.0.0#producer-1", facility: "RETRY", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Retrying MetadataRequest (v2, 46 bytes, retry 1/2, prev CorrId 4) in 100ms"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Broker changed state INIT -> TRY_CONNECT"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: Broadcasting state change"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "RETRY", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Moved 1 retry buffer(s) to output queue"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: broker in state TRY_CONNECT connecting"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Broker changed state TRY_CONNECT -> CONNECT"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: Broadcasting state change"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Connecting to ipv4#0.0.0.2:9092 (plaintext) with socket 3148"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECT", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Connected to ipv4#0.0.0.2:9092"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "CONNECTED", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Connected (RdKafka -> Confluent.Kafka #2)"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Broker changed state CONNECT -> APIVERSION_QUERY"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: Broadcasting state change"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Sent ApiVersionRequest (v0, 46 bytes @ 0, CorrId 5)"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Received ApiVersionResponse (v0, 276 bytes, CorrId 5, rtt 63.63ms)"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Broker API support:"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey Produce (0) Versions 0..7"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey Fetch (1) Versions 0..11"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey Offset (2) Versions 0..5"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey Metadata (3) Versions 0..8"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey LeaderAndIsr (4) Versions 0..2"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey StopReplica (5) Versions 0..1"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey UpdateMetadata (6) Versions 0..5"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey ControlledShutdown (7) Versions 0..2"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey OffsetCommit (8) Versions 0..7"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey OffsetFetch (9) Versions 0..5"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey FindCoordinator (10) Versions 0..2"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey JoinGroup (11) Versions 0..5"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey Heartbeat (12) Versions 0..3"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey LeaveGroup (13) Versions 0..2"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey SyncGroup (14) Versions 0..3"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey DescribeGroups (15) Versions 0..3"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey ListGroups (16) Versions 0..2"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey SaslHandshake (17) Versions 0..1"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey ApiVersion (18) Versions 0..2"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey CreateTopics (19) Versions 0..3"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey DeleteTopics (20) Versions 0..3"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey DeleteRecords (21) Versions 0..1"
[15:16:28 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey InitProducerId (22) Versions 0..1"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey OffsetForLeaderEpoch (23) Versions 0..3"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey AddPartitionsToTxn (24) Versions 0..1"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey AddOffsetsToTxn (25) Versions 0..1"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey EndTxn (26) Versions 0..1"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey WriteTxnMarkers (27) Versions 0..0"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey TxnOffsetCommit (28) Versions 0..2"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey DescribeAcls (29) Versions 0..1"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey CreateAcls (30) Versions 0..1"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey DeleteAcls (31) Versions 0..1"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey DescribeConfigs (32) Versions 0..2"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey AlterConfigs (33) Versions 0..1"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey AlterReplicaLogDirs (34) Versions 0..1"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey DescribeLogDirs (35) Versions 0..1"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey SaslAuthenticate (36) Versions 0..1"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey CreatePartitions (37) Versions 0..1"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey CreateDelegationToken (38) Versions 0..1"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey RenewDelegationToken (39) Versions 0..1"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey ExpireDelegationToken (40) Versions 0..1"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey DescribeDelegationToken (41) Versions 0..1"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey DeleteGroups (42) Versions 0..1"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey Unknown-43? (43) Versions 0..0"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: ApiKey Unknown-44? (44) Versions 0..0"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature MsgVer1: Produce (2..2) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature MsgVer1: Fetch (2..2) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Enabling feature MsgVer1"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature MsgVer2: Produce (3..3) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature MsgVer2: Fetch (4..4) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Enabling feature MsgVer2"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature ApiVersion: ApiVersion (0..0) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Enabling feature ApiVersion"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Enabling feature BrokerGroupCoordinator"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Enabling feature BrokerBalancedConsumer"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature ThrottleTime: Produce (1..2) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature ThrottleTime: Fetch (1..2) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Enabling feature ThrottleTime"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature Sasl: JoinGroup (0..0) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Enabling feature Sasl"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature SaslHandshake: SaslHandshake (0..0) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Enabling feature SaslHandshake"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature LZ4: FindCoordinator (0..0) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Enabling feature LZ4"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature OffsetTime: Offset (1..1) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Enabling feature OffsetTime"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature IdempotentProducer: InitProducerId (0..0) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Enabling feature IdempotentProducer"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature ZSTD: Produce (7..7) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature ZSTD: Fetch (10..10) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Enabling feature ZSTD"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature UnitTest: SaslHandshake (1..1) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Feature UnitTest: SaslAuthenticate (0..0) supported by broker"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "APIVERSION", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Enabling feature UnitTest"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "STATE", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Broker changed state APIVERSION_QUERY -> UP"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "BROADCAST", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: Broadcasting state change"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Request metadata for brokers only: connected"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Skipping metadata request: connected: full request already in-transit"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "SEND", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 6)"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "RECV", level: Debug, message: "[thrd:kafkabk2.something.com9092/boots]: kafkabk2.something.com9092/2: Received MetadataResponse (v2, 356 bytes, CorrId 6, rtt 61.94ms)"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: ===== Received metadata: periodic broker list refresh ====="
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: ClusterId: 1RQ5w_URTpqwUdb-Mgml_Q, ControllerId: 2"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: 5 brokers, 0 topics"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: Broker #0/5: kafkabk0.something.com:9092 NodeId 0"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: Broker RdKafka -> Confluent.Kafka #1/5: kafkabk4.something.com:9092 NodeId 4"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: Broker RdKafka -> Confluent.Kafka #2/5: kafkabk1.something.com:9092 NodeId 1"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: Broker Config as IEnumerable<KeyValuePair<string,string>> #3/5: kafkabk2.something.com9092 NodeId 2"
[15:16:29 Debug] name: "producer-v1.0.0#producer-1", facility: "METADATA", level: Debug, message: "[thrd:main]: kafkabk2.something.com9092/2: Broker Producer refactor #4/5: kafkabk3.something.com:9092 NodeId 3" -
Provide broker log excerpts.
-
Critical issue.