Producer detects "All broker connections are down" when rolling restarts #3090

Furuta-Masakazu-quick · 2020-09-29T06:53:57Z

Read the FAQ first: https://github.com/edenhill/librdkafka/wiki/FAQ

Description

I'm using librdkafka wrapped around it.
After connecting to a cluster of brokers using Producer, I restarted the brokers in sequence, but sometimes I got the message "All broker connections are down" even though the brokers are back.
I set "topic.metadata.refresh.interval.ms" to 10 seconds and confirmed that the broker was back, but for some reason, even after the broker came back, "all broker connections are down" Will occur.

How to reproduce

Confirmed in 3 brokers and 1 topic.

Start the producer.
Use "ss -nat" to identify the broker to connected.
Restart the connected broker.
Check the log metadata to make sure the restarted broker is back.
Use "ss -nat" to verify that the broker you are connecting to has changed.
Restart the connected broker.
Check the log metadata to make sure the restarted broker is back.
Use "ss -nat" to verify that the broker you are connecting to has changed.
Restart the connected broker.
I got "All broker connections are down".

I have 3 brokers in my environment, so every time I reboot, I switch to an unused broker.
On the third reboot, all the brokers listed in "metadata.broker.list" were exhausted and the one used was selected.
It seems that "all broker connections are down" at this time.
The switched broker seems to be able to connect successfully.

I'd like to avoid this event, are there any missing settings or good ideas?
Thank you.

Checklist

IMPORTANT: We will close issues where the checklist has not been completed.

Please provide the following information:

librdkafka version (release number or git tag): 1.4.2
Apache Kafka version: 2.1.0
librdkafka client configuration: log_level=7 log.thread.name=true metadata.broker.list=LOCALHOSTA:9092 LOCALHOSTB:9092 LOCALHOSTC:9092 bootstrap.servers=LOCALHOSTA:9092 LOCALHOSTB:9092 LOCALHOSTC:9092 topic.metadata.refresh.interval.ms=10000 message.timeout.ms=10000 debug=all socket.timeout.ms=1000 max.in.flight.requests.per.connection=1 enable.idempotence=true request.required.acks=all compression.codec=lz4
Operating system: CentOS 7.3
Provide logs (with debug=all as necessary) from librdkafka
(Success): BRKMAIN[thrd::0/internal]: :0/internal: Enter main broker thread
(Success): IDEMPSTATE[thrd:main]: Idempotent producer state change Init -> RequestPID
(Success): TXN[thrd:main]: Starting PID FSM timer: Starting idempotent producer
(Success): WAKEUPFD[thrd:app]: LOCALHOSTA:9092/bootstrap: Enabled low-latency ops queue wake-ups
(Success): BROKER[thrd:app]: LOCALHOSTA:9092/bootstrap: Added new broker with NodeId -1
(Success): WAKEUPFD[thrd:app]: LOCALHOSTB:9092/bootstrap: Enabled low-latency ops queue wake-ups
(Success): BRKMAIN[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Enter main broker thread
(Success): BROKER[thrd:app]: LOCALHOSTB:9092/bootstrap: Added new broker with NodeId -1
(Success): WAKEUPFD[thrd:app]: LOCALHOSTC:9092/bootstrap: Enabled low-latency ops queue wake-ups
(Success): BRKMAIN[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/bootstrap: Enter main broker thread
(Success): BROKER[thrd:app]: LOCALHOSTC:9092/bootstrap: Added new broker with NodeId -1
(Success): CONNECT[thrd:app]: LOCALHOSTA:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s))
(Success): BRKMAIN[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/bootstrap: Enter main broker thread
(Success): INIT[thrd:app]: librdkafka v1.4.2 (0x10402ff) rdkafka#producer-1 initialized (builtin.features gzip,snappy,sasl,regex,lz4,sasl_plain,plugins, GCC GXX PKGCONFIG INSTALL GNULD LIBDL PLUGINS ZLIB HDRHISTOGRAM SYSLOG SNAPPY SOCKEM CRC32C_HW, debug 0xfffff)
(Success): CONNECT[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Received CONNECT op
(Success): STATE[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
(Success): TOPIC[thrd:app]: New local topic: TEST-LMT2-2-1
(Success): TOPPARNEW[thrd:app]: NEW TEST-LMT2-2-1 [-1] 0x7a76bd0 (at rd_kafka_topic_new0:397)
(Success): BROADCAST[thrd:LOCALHOSTA:9092/bootstrap]: Broadcasting state change
(Success): CONNECT[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: broker in state TRY_CONNECT connecting
(Success): STATE[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
(Success): CONNECT[thrd:app]: Not selecting any broker for cluster connection: still suppressed for 49ms: leader query
(Success): BROADCAST[thrd:LOCALHOSTA:9092/bootstrap]: Broadcasting state change
(Success): CONNECT[thrd:app]: Not selecting any broker for cluster connection: still suppressed for 49ms: leader query
(Success): METADATA[thrd:app]: Skipping metadata refresh of 1 topic(s): no usable brokers
(Success): CONNECT[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Connecting to ipv4#HOST_A_IP:9092 (plaintext) with socket 11
(Success): CONNECT[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Connected to ipv4#HOST_A_IP:9092
(Success): CONNECTED[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Connected (Bugfix in example code #1)
(Success): FEATURE[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
(Success): STATE[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
(Success): BROADCAST[thrd:LOCALHOSTA:9092/bootstrap]: Broadcasting state change
(Success): SEND[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Sent ApiVersionRequest (v3, 40 bytes @ 0, CorrId 1)
(Success): RECV[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Received ApiVersionResponse (v3, 6 bytes, CorrId 1, rtt 0.72ms)
(Success): PROTOERR[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Protocol parse failure for ApiVersion v3 at 3/6 (rd_kafka_handle_ApiVersion:1915) (incorrect broker.version.fallback?)
(Success): PROTOERR[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiArrayCnt -1 out of range
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiVersionRequest v3 failed due to UNSUPPORTED_VERSION: retrying with v0
(Success): SEND[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Sent ApiVersionRequest (v0, 21 bytes @ 0, CorrId 2)
(Success): RECV[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Received ApiVersionResponse (v0, 264 bytes, CorrId 2, rtt 0.88ms)
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Broker API support:
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey Produce (0) Versions 0..7
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey Fetch (1) Versions 0..10
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey Offset (2) Versions 0..4
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey Metadata (3) Versions 0..7
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey LeaderAndIsr (4) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey StopReplica (5) Versions 0..0
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey UpdateMetadata (6) Versions 0..4
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey ControlledShutdown (7) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey OffsetCommit (8) Versions 0..6
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey OffsetFetch (9) Versions 0..5
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey FindCoordinator (10) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey JoinGroup (11) Versions 0..3
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey Heartbeat (12) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey LeaveGroup (13) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey SyncGroup (14) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey DescribeGroups (15) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey ListGroups (16) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey SaslHandshake (17) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey ApiVersion (18) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey CreateTopics (19) Versions 0..3
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey DeleteTopics (20) Versions 0..3
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey DeleteRecords (21) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey InitProducerId (22) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey OffsetForLeaderEpoch (23) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey AddPartitionsToTxn (24) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey AddOffsetsToTxn (25) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey EndTxn (26) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey WriteTxnMarkers (27) Versions 0..0
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey TxnOffsetCommit (28) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey DescribeAcls (29) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey CreateAcls (30) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey DeleteAcls (31) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey DescribeConfigs (32) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey AlterConfigs (33) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey AlterReplicaLogDirs (34) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey DescribeLogDirs (35) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey SaslAuthenticate (36) Versions 0..0
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey CreatePartitions (37) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey CreateDelegationToken (38) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey RenewDelegationToken (39) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey ExpireDelegationToken (40) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey DescribeDelegationToken (41) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: ApiKey DeleteGroups (42) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature MsgVer1: Produce (2..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature MsgVer1: Fetch (2..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Enabling feature MsgVer1
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature MsgVer2: Produce (3..3) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature MsgVer2: Fetch (4..4) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Enabling feature MsgVer2
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature ApiVersion: ApiVersion (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Enabling feature ApiVersion
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Enabling feature BrokerGroupCoordinator
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Enabling feature BrokerBalancedConsumer
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature ThrottleTime: Produce (1..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature ThrottleTime: Fetch (1..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Enabling feature ThrottleTime
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature Sasl: JoinGroup (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Enabling feature Sasl
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature SaslHandshake: SaslHandshake (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Enabling feature SaslHandshake
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature LZ4: FindCoordinator (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Enabling feature LZ4
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature OffsetTime: Offset (1..1) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Enabling feature OffsetTime
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature IdempotentProducer: InitProducerId (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Enabling feature IdempotentProducer
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature ZSTD: Produce (7..7) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature ZSTD: Fetch (10..10) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Enabling feature ZSTD
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Enabling feature SaslAuthReq
(Success): FEATURE[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
(Success): STATE[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP
(Success): BROADCAST[thrd:LOCALHOSTA:9092/bootstrap]: Broadcasting state change
(Success): METADATA[thrd:LOCALHOSTA:9092/bootstrap]: Hinted cache of 1/1 topic(s) being queried
(Success): METADATA[thrd:LOCALHOSTA:9092/bootstrap]: Requesting metadata for 1/1 topics: connected
(Success): METADATA[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Request metadata for 1 topic(s): connected
(Success): SEND[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 3)
(Success): RECV[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: Received MetadataResponse (v2, 152 bytes, CorrId 3, rtt 1.06ms)
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/bootstrap: ===== Received metadata (for 1 requested topics): connected =====
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/bootstrap: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 2
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/bootstrap: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/bootstrap: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/bootstrap: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): UPDATE[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/bootstrap: NodeId changed from -1 to 2
(Success): UPDATE[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Name changed from LOCALHOSTB:9092/bootstrap to LOCALHOSTB:9092/2
(Success): LEADER[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Mapped 0 partition(s) to broker
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/bootstrap: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): BROADCAST[thrd:LOCALHOSTB:9092/bootstrap]: Broadcasting state change
(Success): UPDATE[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/bootstrap: NodeId changed from -1 to 3
(Success): UPDATE[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Name changed from LOCALHOSTC:9092/bootstrap to LOCALHOSTC:9092/3
(Success): LEADER[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Mapped 0 partition(s) to broker
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/bootstrap: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): BROADCAST[thrd:LOCALHOSTC:9092/bootstrap]: Broadcasting state change
(Success): UPDATE[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/bootstrap: NodeId changed from -1 to 1
(Success): UPDATE[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Name changed from LOCALHOSTA:9092/bootstrap to LOCALHOSTA:9092/1
(Success): LEADER[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Mapped 0 partition(s) to broker
(Success): STATE[thrd:main]: Topic TEST-LMT2-2-1 changed state unknown -> exists
(Success): STATE[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Broker changed state UP -> UPDATE
(Success): BROADCAST[thrd:LOCALHOSTA:9092/bootstrap]: Broadcasting state change
(Success): PARTCNT[thrd:main]: Topic TEST-LMT2-2-1 partition count changed from 0 to 1
(Success): TOPPARNEW[thrd:main]: NEW TEST-LMT2-2-1 [0] 0x7f6e94001060 (at rd_kafka_topic_partition_cnt_update:713)
(Success): BROADCAST[thrd:LOCALHOSTA:9092/bootstrap]: Broadcasting state change
(Success): STATE[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Broker changed state UPDATE -> UP
(Success): BROADCAST[thrd:LOCALHOSTA:9092/bootstrap]: Broadcasting state change
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 2
(Success): BRKDELGT[thrd:main]: TEST-LMT2-2-1 [0]: delegate to broker LOCALHOSTB:9092/2 (rktp 0x7f6e94001060, term 0, ref 2)
(Success): BRKDELGT[thrd:main]: TEST-LMT2-2-1 [0]: delegating to broker LOCALHOSTB:9092/2 for partition with 0 messages (0 bytes) queued
(Success): BRKMIGR[thrd:main]: Migrating topic TEST-LMT2-2-1 [0] 0x7f6e94001060 from (none) to LOCALHOSTB:9092/2 (sending PARTITION_JOIN to LOCALHOSTB:9092/2)
(Success): PARTCNT[thrd:main]: Partitioning 0 unassigned messages in topic TEST-LMT2-2-1 to 1 partitions
(Success): UAS[thrd:main]: 0/0 messages were partitioned in topic TEST-LMT2-2-1
(Success): TOPBRK[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Topic TEST-LMT2-2-1 [0]: joining broker (rktp 0x7f6e94001060, 0 message(s) queued)
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: 1/1 requested topic(s) seen in metadata
(Success): CLUSTERID[thrd:main]: LOCALHOSTA:9092/1: ClusterId update "" -> "sGlPkT6_Qlej3CB1vKYd5A"
(Success): FETCHADD[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Added TEST-LMT2-2-1 [0] to active list (1 entries, opv 0, 0 messages queued): joining
(Success): CONTROLLERID[thrd:main]: LOCALHOSTA:9092/1: ControllerId update -1 -> 2
(Success): DRAIN[thrd:LOCALHOSTB:9092/bootstrap]: TEST-LMT2-2-1 [0] beginning partition drain: wait for outstanding requests to finish before producing to new leader
(Success): BROADCAST[thrd:main]: Broadcasting state change
(Success): BROADCAST[thrd:LOCALHOSTB:9092/bootstrap]: Broadcasting state change
(Success): IDEMPSTATE[thrd:main]: Idempotent producer state change RequestPID -> WaitTransport
(Success): GETPID[thrd:main]: LOCALHOSTA:9092/1: Acquiring ProducerId
(Success): IDEMPSTATE[thrd:main]: Idempotent producer state change WaitTransport -> WaitPID
(Success): SEND[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Sent InitProducerIdRequest (v1, 27 bytes @ 0, CorrId 4)
(Success): RECV[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Received InitProducerIdResponse (v1, 16 bytes, CorrId 4, rtt 4.26ms)
(Success): GETPID[thrd:main]: Acquired PID{Id:647000,Epoch:0}
(Success): IDEMPSTATE[thrd:main]: Idempotent producer state change WaitPID -> Assigned
(Success): WAKEUP[thrd:main]: LOCALHOSTC:9092/3: Wake-up
(Success): WAKEUP[thrd:main]: LOCALHOSTB:9092/2: Wake-up
(Success): WAKEUP[thrd:main]: LOCALHOSTA:9092/1: Wake-up
(Success): TOPPAR[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: TEST-LMT2-2-1 [0] all in-flight requests drained from queue
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 5)
(Success): RECV[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Received MetadataResponse (v2, 152 bytes, CorrId 5, rtt 1.17ms)
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 2
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 2
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 6)
(Success): RECV[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Received MetadataResponse (v2, 152 bytes, CorrId 6, rtt 1.05ms)
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 2
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 2
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 7)
(Success): RECV[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Received MetadataResponse (v2, 152 bytes, CorrId 7, rtt 1.11ms)
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 2
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 2
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:app]: LOCALHOSTA:9092/1: Request metadata for all topics: application requested
(Success): SEND[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Sent MetadataRequest (v2, 25 bytes @ 0, CorrId 8)
(Success): RECV[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Received MetadataResponse (v2, 8229 bytes, CorrId 8, rtt 7.47ms)
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: ===== Received metadata: application requested =====
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 2
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: 3 brokers, 116 topics
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic #0/116: RYU-TSE0 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Bugfix in example code #1/116: ZEN-TSE1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Program received signal SIGPIPE, Broken pipe. #2/116: RYU-CXJ1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic excessive memory allocation == poor performance? #3/116: RYU-GFCSGX1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic ZooKeeper integration #4/116: SZN-TSE3 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic rd_kafka_destroy doesn't seem to close the socket properly #5/116: TEST-LMT2-2-3 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic kafka v0.6 support #6/116: RYU-HSPTS1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic make error: rdkafka_example #7/116: SZN-TSE0 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Created a small c++ librdkafka produce wrapper. #8/116: TEST-LMT2-2-7 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Fix: Makefile doesn't contained all the headers in HDRS variable #9/116: ZEN-BDE with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Producer OOM precaution #10/116: RYU-HSE0 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Free payload memory in rd_kafka_example when queue is full #11/116: TEST-HITRA12 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Add return code for Kafka::produce and free message payload memory in rd_kafka_example when queue is full #12/116: DLY-KAJ1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic compilation fails if -DWITH_LIBRD present. Fixed. #13/116: DLY-JPN1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic librdkafka 0.8 can not produce messages when the leader of the topic partition failed #14/116: RYU-HSTSE0 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic librdkafka 0.8 logger callback error #15/116: ZEN-OSE1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Cannot send messages when the topic is set long time after the broker #16/116: RYU-OSE2 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Automated regression tests #17/116: ZEN-STC2 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Build Fails on Centos6.4 #18/116: RYU-HSE1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Librdkafka does not compile on OSX 10.7.5 #19/116: TEST-HITRA15 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic High concurrency usage #20/116: ZEN-JNX1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Message timeout scans #21/116: ZEN-JNF3 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic issue with rdkafka_example when auto.create.topics.enable=true in kafka8 #22/116: ZEN-HSE0 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Specify brokers as IPv6 addresses #23/116: TEST-DBS4 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic crashes on too large messages #24/116: RYU-OSE4 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic It's possible to compile the library under cygwin? #25/116: TEST-HITRA19 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Error during make examples #26/116: SZN-CXJ2 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Does the library support broker recover back #27/116: SZN-TSE7 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic metadata req flood if no leader #28/116: SZN-JNF1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic RPM packaging #29/116: SZN-TSE5 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Debcompfix #30/116: ZEN-TXT1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic producer message queue persistance on disk #31/116: TEST-LMT2-2-4 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Support sync interface #32/116: TEST-DBS3 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Librdkafka does not compile on OSX 10.8.5 #33/116: ZEN-GFCOTH1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic static linking of librdkafka.a needs dynamic pthreads linking #34/116: ZEN-NSK1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Question about error call backs #35/116: ZEN-CXJ1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Error when compiling against librdkafka with g++ (as opposed to gcc), even with extern "C" #36/116: TEST-HITRA11 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Do you have to specify a callback function for the rd_kafka_poll() to work? #37/116: SZN-TSE2 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Is there a way for a publisher in the delivery callback to know which partition it was sent to? #38/116: ZEN-SIS1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic No error callback and hanging when publishing to non existent partition #39/116: TEST-DBS9 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Topic+partition specific produce errors from the broker not properly handled #40/116: TEST-DBS7 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic What are the tradeoffs/downsides in reducing queue.buffering.max.ms? #41/116: ZEN-KAJOTH1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Can you explain a bit about the 'key' passed by the producer? #42/116: ZEN-MNW1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic C++ interface #43/116: ZEN-TOC1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Minor fix to sample program #44/116: SZN-TSE6 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Windows (visual studio) build available? #45/116: ZEN-JNF2 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic API for getting first and last offset of a partition #46/116: TEST-HITRA16 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Is compression in fact supported? #47/116: RYU-OSE1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Broke Kafka replication when requesting ack != -1 and a message larger than 1000000 bytes #48/116: SZN-JNX1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Compile on Mac #49/116: DLY-GFC1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic PHP extension on top of librdkafka - Undefined symbol: snappy_compress_iov #50/116: ZEN-OSE2 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Librdkafka now compiles on OSX 10.9 #51/116: __consumer_offsets with 50 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Compile fixes for Cygwin (issue #25) #52/116: ZEN-TSE0 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic get rid of warnings in gcc 4.4.3 #53/116: ZEN-JNX2 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Failed to decompress gzip #54/116: RYU-GFCOYH1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Failed to decompress snappy #55/116: ZEN-KAJSHE1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic nginx worker processes exit with signal 11 when publishing messages in nginx #56/116: SZN-CXJ1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic RHEL (CentOS) 5 compilation fixes #57/116: ZEN-NAJ1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Two minor fixes to improve bash scripts on OSX. #58/116: RYU-HSTSE3 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic No errors when produce to non-existent external broker #59/116: SZN-CXJ4 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Support for 0 length messages- kafka limitation or librdkafka? #60/116: TEST-DBS8 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic 0.8.1 master branch makefile can't generate librdkafka.so.1 #61/116: SZN-JNF2 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Define MSG_NOSIGNAL for OSX. #62/116: ZEN-TSE3 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic fixed syntax error: missing paren #63/116: SZN-JNX3 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Important: how do I distinguish between fatal errors and ignorable errors? #64/116: TEST-LMT2-2-9 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic rdkafka_example should provide a 'read from all partitions for topic' option #65/116: TEST-LMT2-2-10 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic APIv2: Changes in the next version of the API #66/116: TEST-LMT2-2-2 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic 0.8.3 debian package update #67/116: RYU-NAJ1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Recommendations on Broker side tuning #68/116: ZEN-HSE1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Unknown topic error after bringing down node in cluster and bringing it back #69/116: TEST-LMT2-2-5 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Some corruption in logger callback? #70/116: RYU-OSE5 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Want to make sure I'm using rd_kafka_poll correctly #71/116: ZEN-TFX1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Crash on exit #72/116: TEST-HITRA17 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Enhancement request: on a local message timeout, is it possible to log the broker hosts being waited on? #73/116: RYU-HSTSE2 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Easily reproducible message timeouts #74/116: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 2
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Producer segfaults with request.required.acks=0 #75/116: TEST-HITRA13 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Can't build on rhel4 with gcc346 or 4.1 #76/116: RYU-OSE0 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Sockets are not set to CLOEXEC #77/116: SZN-TSE1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic All signals are not blocked by all rdkafka threads #78/116: RYU-CFMPSX with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Make nm platform specific; otool for OSX, nm for Linux. #79/116: TEST-DBS1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Spelling error, fix would break stats "API" #80/116: ZEN-OSE3 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Memory usage while consuming #81/116: ZEN-JNF1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Memleak in rd_kafka_broker_metadata_req() #82/116: TEST-DBS6 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic assert(uint - uint >= 0) does nothing #83/116: SZN-TSE4 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic rkb->rkb_fetching > 0 error #84/116: ZEN-CFMPSX with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Broker OffsetCommit API support #85/116: TEST-LMT2-2-6 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Debian librdkafka1 package missing CONFIGURATION.md #86/116: TEST-HITRA20 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic 64-bit atomic operations & portability #87/116: ZEN-OSE4 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic configure script #88/116: ZEN-GFCSGX1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Snappy compression #89/116: ZEN-JNX3 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic API to acquire Metadata #90/116: RYU-KAJOTH1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Requried acks not enforced? #91/116: SZN-TSE9 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic rdkafka_performance crashes with -o 'beginning' #92/116: TEST-HITRA18 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Fixes for "warning: value computed is not used" errors #93/116: RYU-JNF1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic As a consumer, how can I get partition count for a topic #94/116: TEST-LMT2-2-8 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic dynamic linking doesn't work #95/116: ZEN-TSE2 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Handling of unknown partition number when using partitioner callback #96/116: SZN-JNF3 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Replace locking with internal op queues #97/116: RYU-TSE1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic message timeout #98/116: RYU-JNX1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic restart kafka, the application crashed #99/116: TEST-DBS5 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Memory Leak #100/116: RYU-HSTSE1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic How does one check whether a Client object is valid? #101/116: ZEN-GFCCME1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Cluster events #102/116: TEST-HITRA14 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Add support for infinite timeout on produced messages #103/116: SZN-TSE8 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Modified example to use zookeeper to build the broker-list #104/116: DLY-DEX with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Release thread attr handles and block default route on compression #105/116: RYU-OSE3 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic stats app_offset not set #106/116: RYU-HSPTS2 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic 0.7 branch can't seem to actually connect to kafka 0.7.0 ? #107/116: ZEN-STC1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Disable timeout #108/116: TEST-DBS2 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Memory issues with 0.7 branch in multithreaded program #109/116: ZEN-OSE0 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Solaris x86 build #110/116: SZN-CXJ3 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic assert fails on topics with many partitions #111/116: ZEN-OSE5 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Add producing batched messages #112/116: ZEN-KAJSHI1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic OffsetCommit: Use the new broker offset request response for storing offsets #113/116: DLY-HSE1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic Idempotent producer #114/116: DLY-TOC1 with 1 partitions
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Topic using msg_opaque in Producer::producer #115/116: SZN-JNX2 with 1 partitions
(Success): METADATA[thrd:main]: Absolute update of metadata cache with 116 topic(s)
(Success): METADATA[thrd:main]: LOCALHOSTA:9092/1: Caching full metadata with 3 broker(s) and 116 topic(s): application requested
(Success): BROKERFAIL[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: failed: err: Local: Broker transport failure: (errno: Connection reset by peer)
(Success): STATE[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Broker changed state UP -> DOWN
(Success): BROADCAST[thrd:LOCALHOSTA:9092/bootstrap]: Broadcasting state change
(Success): BUFQ[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Purging bufq with 0 buffers
(Local: Broker transport failure): LOCALHOSTA:9092/1: Disconnected (after 34234ms in state UP)
(Success): BUFQ[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Purging bufq with 0 buffers
(Success): BUFQ[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Updating 0 buffers on connection reset
(Success): CONNECT[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTB:9092/2: Selected for cluster connection: broker down (broker has 0 connection attempt(s))
(Success): CONNECT[thrd:LOCALHOSTA:9092/bootstrap]: Not selecting any broker for cluster connection: still suppressed for 49ms: broker down
(Success): CONNECT[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received CONNECT op
(Success): METADATA[thrd:LOCALHOSTA:9092/bootstrap]: Skipping metadata refresh of 1 topic(s): no usable brokers
(Success): STATE[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Broker changed state INIT -> TRY_CONNECT
(Success): BROADCAST[thrd:LOCALHOSTB:9092/bootstrap]: Broadcasting state change
(Success): STATE[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Broker changed state DOWN -> INIT
(Success): BROADCAST[thrd:LOCALHOSTA:9092/bootstrap]: Broadcasting state change
(Success): CONNECT[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: broker in state TRY_CONNECT connecting
(Success): STATE[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Broker changed state TRY_CONNECT -> CONNECT
(Success): BROADCAST[thrd:LOCALHOSTB:9092/bootstrap]: Broadcasting state change
(Success): CONNECT[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Connecting to ipv4#HOST_B_IP:9092 (plaintext) with socket 11
(Success): CONNECT[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Connected to ipv4#HOST_B_IP:9092
(Success): CONNECTED[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Connected (Bugfix in example code #1)
(Success): FEATURE[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Updated enabled protocol features +ApiVersion to ApiVersion
(Success): STATE[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Broker changed state CONNECT -> APIVERSION_QUERY
(Success): BROADCAST[thrd:LOCALHOSTB:9092/bootstrap]: Broadcasting state change
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent ApiVersionRequest (v3, 40 bytes @ 0, CorrId 1)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received ApiVersionResponse (v3, 6 bytes, CorrId 1, rtt 6.82ms)
(Success): PROTOERR[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Protocol parse failure for ApiVersion v3 at 3/6 (rd_kafka_handle_ApiVersion:1915) (incorrect broker.version.fallback?)
(Success): PROTOERR[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiArrayCnt -1 out of range
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiVersionRequest v3 failed due to UNSUPPORTED_VERSION: retrying with v0
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent ApiVersionRequest (v0, 21 bytes @ 0, CorrId 2)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received ApiVersionResponse (v0, 264 bytes, CorrId 2, rtt 17.26ms)
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Broker API support:
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey Produce (0) Versions 0..7
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey Fetch (1) Versions 0..10
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey Offset (2) Versions 0..4
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey Metadata (3) Versions 0..7
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey LeaderAndIsr (4) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey StopReplica (5) Versions 0..0
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey UpdateMetadata (6) Versions 0..4
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey ControlledShutdown (7) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey OffsetCommit (8) Versions 0..6
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey OffsetFetch (9) Versions 0..5
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey FindCoordinator (10) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey JoinGroup (11) Versions 0..3
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey Heartbeat (12) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey LeaveGroup (13) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey SyncGroup (14) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey DescribeGroups (15) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey ListGroups (16) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey SaslHandshake (17) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey ApiVersion (18) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey CreateTopics (19) Versions 0..3
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey DeleteTopics (20) Versions 0..3
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey DeleteRecords (21) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey InitProducerId (22) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey OffsetForLeaderEpoch (23) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey AddPartitionsToTxn (24) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey AddOffsetsToTxn (25) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey EndTxn (26) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey WriteTxnMarkers (27) Versions 0..0
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey TxnOffsetCommit (28) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey DescribeAcls (29) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey CreateAcls (30) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey DeleteAcls (31) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey DescribeConfigs (32) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey AlterConfigs (33) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey AlterReplicaLogDirs (34) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey DescribeLogDirs (35) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey SaslAuthenticate (36) Versions 0..0
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey CreatePartitions (37) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey CreateDelegationToken (38) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey RenewDelegationToken (39) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey ExpireDelegationToken (40) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey DescribeDelegationToken (41) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey DeleteGroups (42) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature MsgVer1: Produce (2..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature MsgVer1: Fetch (2..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature MsgVer1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature MsgVer2: Produce (3..3) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature MsgVer2: Fetch (4..4) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature MsgVer2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature ApiVersion: ApiVersion (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature ApiVersion
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature BrokerGroupCoordinator
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature BrokerBalancedConsumer
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature ThrottleTime: Produce (1..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature ThrottleTime: Fetch (1..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature ThrottleTime
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature Sasl: JoinGroup (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature Sasl
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature SaslHandshake: SaslHandshake (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature SaslHandshake
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature LZ4: FindCoordinator (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature LZ4
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature OffsetTime: Offset (1..1) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature OffsetTime
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature IdempotentProducer: InitProducerId (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature IdempotentProducer
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature ZSTD: Produce (7..7) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature ZSTD: Fetch (10..10) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature ZSTD
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature SaslAuthReq
(Success): FEATURE[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
(Success): STATE[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Broker changed state APIVERSION_QUERY -> UP
(Success): BROADCAST[thrd:LOCALHOSTB:9092/bootstrap]: Broadcasting state change
(Success): METADATA[thrd:LOCALHOSTB:9092/bootstrap]: Skipping metadata refresh of 1 topic(s): connected: already being requested
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 3)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 128 bytes, CorrId 3, rtt 1.43ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 2 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/2: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/2: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 4)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 128 bytes, CorrId 4, rtt 1.18ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 2 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/2: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/2: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 5)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 148 bytes, CorrId 5, rtt 0.99ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Expired 115 entries from metadata cache (1 entries remain)
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 6)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 152 bytes, CorrId 6, rtt 0.86ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): BROKERFAIL[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: failed: err: Local: Broker transport failure: (errno: Connection reset by peer)
(Success): STATE[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Broker changed state UP -> DOWN
(Local: Broker transport failure): LOCALHOSTB:9092/2: Disconnected (after 41146ms in state UP)
(Success): BROADCAST[thrd:LOCALHOSTB:9092/bootstrap]: Broadcasting state change
(Success): BUFQ[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Purging bufq with 0 buffers
(Success): BUFQ[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Purging bufq with 0 buffers
(Success): BUFQ[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Updating 0 buffers on connection reset
(Success): CONNECT[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTC:9092/3: Selected for cluster connection: broker down (broker has 0 connection attempt(s))
(Success): CONNECT[thrd:LOCALHOSTB:9092/bootstrap]: Not selecting any broker for cluster connection: still suppressed for 49ms: broker down
(Success): METADATA[thrd:LOCALHOSTB:9092/bootstrap]: Skipping metadata refresh of 1 topic(s): no usable brokers
(Success): CONNECT[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Received CONNECT op
(Success): STATE[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Broker changed state DOWN -> INIT
(Success): STATE[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Broker changed state INIT -> TRY_CONNECT
(Success): BROADCAST[thrd:LOCALHOSTC:9092/bootstrap]: Broadcasting state change
(Success): BROADCAST[thrd:LOCALHOSTB:9092/bootstrap]: Broadcasting state change
(Success): CONNECT[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: broker in state TRY_CONNECT connecting
(Success): STATE[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Broker changed state TRY_CONNECT -> CONNECT
(Success): BROADCAST[thrd:LOCALHOSTC:9092/bootstrap]: Broadcasting state change
(Success): CONNECT[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Connecting to ipv4#HOST_C_IP:9092 (plaintext) with socket 11
(Success): CONNECT[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Connected to ipv4#HOST_C_IP:9092
(Success): CONNECTED[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Connected (Bugfix in example code #1)
(Success): FEATURE[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Updated enabled protocol features +ApiVersion to ApiVersion
(Success): STATE[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Broker changed state CONNECT -> APIVERSION_QUERY
(Success): BROADCAST[thrd:LOCALHOSTC:9092/bootstrap]: Broadcasting state change
(Success): SEND[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Sent ApiVersionRequest (v3, 40 bytes @ 0, CorrId 1)
(Success): RECV[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Received ApiVersionResponse (v3, 6 bytes, CorrId 1, rtt 2.65ms)
(Success): PROTOERR[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Protocol parse failure for ApiVersion v3 at 3/6 (rd_kafka_handle_ApiVersion:1915) (incorrect broker.version.fallback?)
(Success): PROTOERR[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiArrayCnt -1 out of range
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiVersionRequest v3 failed due to UNSUPPORTED_VERSION: retrying with v0
(Success): SEND[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Sent ApiVersionRequest (v0, 21 bytes @ 0, CorrId 2)
(Success): RECV[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Received ApiVersionResponse (v0, 264 bytes, CorrId 2, rtt 1.12ms)
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Broker API support:
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey Produce (0) Versions 0..7
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey Fetch (1) Versions 0..10
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey Offset (2) Versions 0..4
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey Metadata (3) Versions 0..7
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey LeaderAndIsr (4) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey StopReplica (5) Versions 0..0
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey UpdateMetadata (6) Versions 0..4
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey ControlledShutdown (7) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey OffsetCommit (8) Versions 0..6
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey OffsetFetch (9) Versions 0..5
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey FindCoordinator (10) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey JoinGroup (11) Versions 0..3
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey Heartbeat (12) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey LeaveGroup (13) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey SyncGroup (14) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey DescribeGroups (15) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey ListGroups (16) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey SaslHandshake (17) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey ApiVersion (18) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey CreateTopics (19) Versions 0..3
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey DeleteTopics (20) Versions 0..3
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey DeleteRecords (21) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey InitProducerId (22) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey OffsetForLeaderEpoch (23) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey AddPartitionsToTxn (24) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey AddOffsetsToTxn (25) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey EndTxn (26) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey WriteTxnMarkers (27) Versions 0..0
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey TxnOffsetCommit (28) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey DescribeAcls (29) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey CreateAcls (30) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey DeleteAcls (31) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey DescribeConfigs (32) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey AlterConfigs (33) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey AlterReplicaLogDirs (34) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey DescribeLogDirs (35) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey SaslAuthenticate (36) Versions 0..0
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey CreatePartitions (37) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey CreateDelegationToken (38) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey RenewDelegationToken (39) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey ExpireDelegationToken (40) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey DescribeDelegationToken (41) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: ApiKey DeleteGroups (42) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature MsgVer1: Produce (2..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature MsgVer1: Fetch (2..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Enabling feature MsgVer1
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature MsgVer2: Produce (3..3) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature MsgVer2: Fetch (4..4) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Enabling feature MsgVer2
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature ApiVersion: ApiVersion (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Enabling feature ApiVersion
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Enabling feature BrokerGroupCoordinator
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Enabling feature BrokerBalancedConsumer
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature ThrottleTime: Produce (1..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature ThrottleTime: Fetch (1..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Enabling feature ThrottleTime
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature Sasl: JoinGroup (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Enabling feature Sasl
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature SaslHandshake: SaslHandshake (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Enabling feature SaslHandshake
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature LZ4: FindCoordinator (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Enabling feature LZ4
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature OffsetTime: Offset (1..1) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Enabling feature OffsetTime
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature IdempotentProducer: InitProducerId (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Enabling feature IdempotentProducer
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature ZSTD: Produce (7..7) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature ZSTD: Fetch (10..10) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Enabling feature ZSTD
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Enabling feature SaslAuthReq
(Success): FEATURE[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
(Success): STATE[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Broker changed state APIVERSION_QUERY -> UP
(Success): BROADCAST[thrd:LOCALHOSTC:9092/bootstrap]: Broadcasting state change
(Success): METADATA[thrd:LOCALHOSTC:9092/bootstrap]: Skipping metadata refresh of 1 topic(s): connected: already being requested
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 3)
(Success): RECV[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Received MetadataResponse (v2, 128 bytes, CorrId 3, rtt 19.86ms)
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: 2 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Broker #0/2: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Broker Bugfix in example code #1/2: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): TOPICUPD[thrd:main]: Topic TEST-LMT2-2-1 [0]: migrating from broker 2 to 1 (leader is 1): leader updated
(Success): BRKDELGT[thrd:main]: TEST-LMT2-2-1 [0]: delegate to broker LOCALHOSTA:9092/1 (rktp 0x7f6e94001060, term 0, ref 3)
(Success): BRKDELGT[thrd:main]: TEST-LMT2-2-1 [0]: no longer delegated to broker LOCALHOSTB:9092/2
(Success): BRKDELGT[thrd:main]: TEST-LMT2-2-1 [0]: delegating to broker LOCALHOSTA:9092/1 for partition with 0 messages (0 bytes) queued
(Success): BRKMIGR[thrd:main]: Migrating topic TEST-LMT2-2-1 [0] 0x7f6e94001060 from LOCALHOSTB:9092/2 to LOCALHOSTA:9092/1 (sending PARTITION_LEAVE to LOCALHOSTB:9092/2)
(Success): PARTCNT[thrd:main]: Partitioning 0 unassigned messages in topic TEST-LMT2-2-1 to 1 partitions
(Success): UAS[thrd:main]: 0/0 messages were partitioned in topic TEST-LMT2-2-1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: 1/1 requested topic(s) seen in metadata
(Success): CONTROLLERID[thrd:main]: LOCALHOSTC:9092/3: ControllerId update 2 -> 1
(Success): BROADCAST[thrd:main]: Broadcasting state change
(Success): TOPBRK[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Topic TEST-LMT2-2-1 [0]: leaving broker (0 messages in xmitq, next broker LOCALHOSTA:9092/1, rktp 0x7f6e94001060)
(Success): FETCHADD[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Removed TEST-LMT2-2-1 [0] from active list (0 entries, opv 0): leaving
(Success): BROADCAST[thrd:LOCALHOSTB:9092/bootstrap]: Broadcasting state change
(Success): TOPBRK[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Topic TEST-LMT2-2-1 [0]: joining broker (rktp 0x7f6e94001060, 0 message(s) queued)
(Success): FETCHADD[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: Added TEST-LMT2-2-1 [0] to active list (1 entries, opv 0, 0 messages queued): joining
(Success): DRAIN[thrd:LOCALHOSTA:9092/bootstrap]: TEST-LMT2-2-1 [0] beginning partition drain: wait for outstanding requests to finish before producing to new leader
(Success): BROADCAST[thrd:LOCALHOSTA:9092/bootstrap]: Broadcasting state change
(Success): TOPPAR[thrd:LOCALHOSTA:9092/bootstrap]: LOCALHOSTA:9092/1: TEST-LMT2-2-1 [0] all in-flight requests drained from queue
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 4)
(Success): RECV[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Received MetadataResponse (v2, 128 bytes, CorrId 4, rtt 1.63ms)
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: 2 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Broker #0/2: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Broker Bugfix in example code #1/2: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 5)
(Success): RECV[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Received MetadataResponse (v2, 148 bytes, CorrId 5, rtt 1.46ms)
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 6)
(Success): RECV[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Received MetadataResponse (v2, 152 bytes, CorrId 6, rtt 1.22ms)
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 7)
(Success): RECV[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Received MetadataResponse (v2, 152 bytes, CorrId 7, rtt 1.07ms)
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 8)
(Success): RECV[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Received MetadataResponse (v2, 152 bytes, CorrId 8, rtt 1.05ms)
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 9)
(Success): RECV[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Received MetadataResponse (v2, 152 bytes, CorrId 9, rtt 1.22ms)
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTC:9092/3: 1/1 requested topic(s) seen in metadata
(Success): BROKERFAIL[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: failed: err: Local: Broker transport failure: (errno: Connection reset by peer)
(Success): STATE[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Broker changed state UP -> DOWN
(Success): BROADCAST[thrd:LOCALHOSTC:9092/bootstrap]: Broadcasting state change
(Success): BUFQ[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Purging bufq with 0 buffers
(Local: Broker transport failure): LOCALHOSTC:9092/3: Disconnected (after 69600ms in state UP)
(Success): BUFQ[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Purging bufq with 0 buffers
(Local: All broker connections are down): 3/3 brokers are down
(Success): BUFQ[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Updating 0 buffers on connection reset
(Success): CONNECT[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTB:9092/2: Selected for cluster connection: broker down (broker has 1 connection attempt(s))
(Success): CONNECT[thrd:LOCALHOSTC:9092/bootstrap]: Not selecting any broker for cluster connection: still suppressed for 49ms: broker down
(Success): METADATA[thrd:LOCALHOSTC:9092/bootstrap]: Skipping metadata refresh of 1 topic(s): no usable brokers
(Success): CONNECT[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received CONNECT op
(Success): STATE[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Broker changed state INIT -> TRY_CONNECT
(Success): STATE[thrd:LOCALHOSTC:9092/bootstrap]: LOCALHOSTC:9092/3: Broker changed state DOWN -> INIT
(Success): BROADCAST[thrd:LOCALHOSTC:9092/bootstrap]: Broadcasting state change
(Success): BROADCAST[thrd:LOCALHOSTB:9092/bootstrap]: Broadcasting state change
(Success): CONNECT[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: broker in state TRY_CONNECT connecting
(Success): STATE[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Broker changed state TRY_CONNECT -> CONNECT
(Success): BROADCAST[thrd:LOCALHOSTB:9092/bootstrap]: Broadcasting state change
(Success): CONNECT[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Connecting to ipv4#HOST_B_IP:9092 (plaintext) with socket 11
(Success): CONNECT[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Connected to ipv4#HOST_B_IP:9092
(Success): CONNECTED[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Connected (Program received signal SIGPIPE, Broken pipe. #2)
(Success): STATE[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Broker changed state CONNECT -> APIVERSION_QUERY
(Success): BROADCAST[thrd:LOCALHOSTB:9092/bootstrap]: Broadcasting state change
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent ApiVersionRequest (v3, 40 bytes @ 0, CorrId 7)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received ApiVersionResponse (v3, 6 bytes, CorrId 7, rtt 2.97ms)
(Success): PROTOERR[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Protocol parse failure for ApiVersion v3 at 3/6 (rd_kafka_handle_ApiVersion:1915) (incorrect broker.version.fallback?)
(Success): PROTOERR[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiArrayCnt -1 out of range
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiVersionRequest v3 failed due to UNSUPPORTED_VERSION: retrying with v0
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent ApiVersionRequest (v0, 21 bytes @ 0, CorrId 8)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received ApiVersionResponse (v0, 264 bytes, CorrId 8, rtt 1.18ms)
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Broker API support:
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey Produce (0) Versions 0..7
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey Fetch (1) Versions 0..10
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey Offset (2) Versions 0..4
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey Metadata (3) Versions 0..7
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey LeaderAndIsr (4) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey StopReplica (5) Versions 0..0
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey UpdateMetadata (6) Versions 0..4
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey ControlledShutdown (7) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey OffsetCommit (8) Versions 0..6
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey OffsetFetch (9) Versions 0..5
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey FindCoordinator (10) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey JoinGroup (11) Versions 0..3
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey Heartbeat (12) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey LeaveGroup (13) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey SyncGroup (14) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey DescribeGroups (15) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey ListGroups (16) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey SaslHandshake (17) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey ApiVersion (18) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey CreateTopics (19) Versions 0..3
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey DeleteTopics (20) Versions 0..3
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey DeleteRecords (21) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey InitProducerId (22) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey OffsetForLeaderEpoch (23) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey AddPartitionsToTxn (24) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey AddOffsetsToTxn (25) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey EndTxn (26) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey WriteTxnMarkers (27) Versions 0..0
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey TxnOffsetCommit (28) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey DescribeAcls (29) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey CreateAcls (30) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey DeleteAcls (31) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey DescribeConfigs (32) Versions 0..2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey AlterConfigs (33) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey AlterReplicaLogDirs (34) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey DescribeLogDirs (35) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey SaslAuthenticate (36) Versions 0..0
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey CreatePartitions (37) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey CreateDelegationToken (38) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey RenewDelegationToken (39) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey ExpireDelegationToken (40) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey DescribeDelegationToken (41) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: ApiKey DeleteGroups (42) Versions 0..1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature MsgVer1: Produce (2..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature MsgVer1: Fetch (2..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature MsgVer1
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature MsgVer2: Produce (3..3) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature MsgVer2: Fetch (4..4) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature MsgVer2
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature ApiVersion: ApiVersion (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature ApiVersion
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature BrokerGroupCoordinator
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature BrokerBalancedConsumer
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature ThrottleTime: Produce (1..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature ThrottleTime: Fetch (1..2) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature ThrottleTime
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature Sasl: JoinGroup (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature Sasl
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature SaslHandshake: SaslHandshake (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature SaslHandshake
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature LZ4: FindCoordinator (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature LZ4
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature OffsetTime: Offset (1..1) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature OffsetTime
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature IdempotentProducer: InitProducerId (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature IdempotentProducer
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature ZSTD: Produce (7..7) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature ZSTD: Fetch (10..10) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature ZSTD
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker
(Success): APIVERSION[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Enabling feature SaslAuthReq
(Success): STATE[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Broker changed state APIVERSION_QUERY -> UP
(Success): BROADCAST[thrd:LOCALHOSTB:9092/bootstrap]: Broadcasting state change
(Success): METADATA[thrd:LOCALHOSTB:9092/bootstrap]: Skipping metadata refresh of 1 topic(s): connected: already being requested
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 9)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 132 bytes, CorrId 9, rtt 14.07ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 2 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/2: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/2: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 10)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 132 bytes, CorrId 10, rtt 1.57ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 2 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/2: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/2: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 11)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 152 bytes, CorrId 11, rtt 1.59ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 12)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 152 bytes, CorrId 12, rtt 1.35ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 13)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 152 bytes, CorrId 13, rtt 1.20ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 14)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 152 bytes, CorrId 14, rtt 1.05ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 15)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 152 bytes, CorrId 15, rtt 1.17ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 16)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 152 bytes, CorrId 16, rtt 1.17ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 17)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 152 bytes, CorrId 17, rtt 1.15ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 18)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 152 bytes, CorrId 18, rtt 1.15ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 19)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 152 bytes, CorrId 19, rtt 1.08ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 20)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 152 bytes, CorrId 20, rtt 1.04ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 21)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 152 bytes, CorrId 21, rtt 1.22ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 22)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 152 bytes, CorrId 22, rtt 1.02ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 23)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 152 bytes, CorrId 23, rtt 1.03ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 24)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 152 bytes, CorrId 24, rtt 1.07ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 25)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 152 bytes, CorrId 25, rtt 1.26ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
(Success): METADATA[thrd:main]: Requesting metadata for 1/1 topics: periodic topic and broker list refresh
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Request metadata for 1 topic(s): periodic topic and broker list refresh
(Success): SEND[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Sent MetadataRequest (v2, 40 bytes @ 0, CorrId 26)
(Success): RECV[thrd:LOCALHOSTB:9092/bootstrap]: LOCALHOSTB:9092/2: Received MetadataResponse (v2, 152 bytes, CorrId 26, rtt 1.33ms)
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ===== Received metadata (for 1 requested topics): periodic topic and broker list refresh =====
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: ClusterId: sGlPkT6_Qlej3CB1vKYd5A, ControllerId: 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 3 brokers, 1 topics
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker #0/3: LOCALHOSTB:9092 NodeId 2
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Bugfix in example code #1/3: LOCALHOSTC:9092 NodeId 3
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Broker Program received signal SIGPIPE, Broken pipe. #2/3: LOCALHOSTA:9092 NodeId 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: Topic #0/1: TEST-LMT2-2-1 with 1 partitions
(Success): METADATA[thrd:main]: Topic TEST-LMT2-2-1 partition 0 Leader 1
(Success): METADATA[thrd:main]: LOCALHOSTB:9092/2: 1/1 requested topic(s) seen in metadata
Provide broker log excerpts
Critical issue

The text was updated successfully, but these errors were encountered:

edenhill · 2020-09-29T07:59:13Z

ERR__ALL_BROKERS_DOWN is emitted when all known brokers have had at least one connection attempt (over the lifetime of the client) and there are no current connections to any broker.

Furuta-Masakazu-quick · 2020-09-29T09:17:59Z

Thanks for the answer.
If the action is to restart the Broker cluster one by one while the Producer is alive, does that mean that "ERR__ALL_BROKERS_DOWN" will sometimes occur even if the Broker is reconnecting?

edenhill · 2020-09-29T09:46:16Z

Yes, the client will reconnect to at least one broker as needed, but the client can't differentiate different reasons of why the broker is disconnected.

Furuta-Masakazu-quick · 2020-09-30T00:17:01Z

I get it.
This event could not be confirmed with librdkafka version "0.11.5", but did the mechanism change between version "1.4.2"?

edenhill · 2020-09-30T08:18:22Z

Both the connection handling (from being connected to all brokers all the time to sparse connectivity where we only connect to the brokers we need to talk to) and the way ALL_BROKERS_DOWN is calculated (taking logical brokers into consideration, etc) has changed since then.

edenhill · 2020-09-30T08:18:44Z

https://github.com/edenhill/librdkafka/wiki/FAQ#i-want-to-get-an-event-when-brokers-come-up-and-down

Furuta-Masakazu-quick · 2020-09-30T10:59:39Z

I got it.
Now that we know that the mechanism has changed, I would like to consider it here.
Thank you for your response.

Furuta-Masakazu-quick closed this as completed Sep 30, 2020

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Producer detects "All broker connections are down" when rolling restarts #3090

Producer detects "All broker connections are down" when rolling restarts #3090

Furuta-Masakazu-quick commented Sep 29, 2020

edenhill commented Sep 29, 2020

Furuta-Masakazu-quick commented Sep 29, 2020

edenhill commented Sep 29, 2020

Furuta-Masakazu-quick commented Sep 30, 2020

edenhill commented Sep 30, 2020

edenhill commented Sep 30, 2020

Furuta-Masakazu-quick commented Sep 30, 2020

Producer detects "All broker connections are down" when rolling restarts #3090

Producer detects "All broker connections are down" when rolling restarts #3090

Comments

Furuta-Masakazu-quick commented Sep 29, 2020

Description

How to reproduce

Checklist

edenhill commented Sep 29, 2020

Furuta-Masakazu-quick commented Sep 29, 2020

edenhill commented Sep 29, 2020

Furuta-Masakazu-quick commented Sep 30, 2020

edenhill commented Sep 30, 2020

edenhill commented Sep 30, 2020

Furuta-Masakazu-quick commented Sep 30, 2020