kcat ERROR: Local: Broker transport failure: sasl_plaintext://brokerhost:6667/bootstrap: Receive failed: Disconnected

ERROR: Local: Broker transport failure: sasl_plaintext://brokerhost:6667/bootstrap: Receive failed: Disconnected

Open apellegr06 opened this issue 3 years ago • 2 comments
Hello,
I get an error when consuming from one specific kafka broker (it's working on all others with the same kafkacat instance). When I try to consume, I got the following error:
% ERROR: Local: Broker transport failure: sasl_plaintext://brokerhost:6667/bootstrap: Receive failed: Disconnected
And then, this error for each broker in the cluster :
% ERROR: Local: Broker transport failure: sasl_plaintext://host1:6667/<broker_id>: Receive failed: Disconnected
Here is the used command :
kafkacat -C -b brokerhost:6667 -t TOPIC
I don't understand why !
Thank you Alain
Jul 28 '21 13:07 apellegr06
Here is the result with "-d all" :
%7|1627884413.880|APIVERSION|rdkafka#consumer-1| [thrd:broker05:6667/5]: broker05:6667/5: Enabling feature BrokerBalancedConsumer
%7|1627884413.880|APIVERSION|rdkafka#consumer-1| [thrd:broker05:6667/5]: broker05:6667/5:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1627884413.880|APIVERSION|rdkafka#consumer-1| [thrd:broker05:6667/5]: broker05:6667/5:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1627884413.880|APIVERSION|rdkafka#consumer-1| [thrd:broker05:6667/5]: broker05:6667/5: Enabling feature ThrottleTime
%7|1627884413.880|APIVERSION|rdkafka#consumer-1| [thrd:broker05:6667/5]: broker05:6667/5:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1627884413.880|APIVERSION|rdkafka#consumer-1| [thrd:broker05:6667/5]: broker05:6667/5: Enabling feature Sasl
%7|1627884413.880|APIVERSION|rdkafka#consumer-1| [thrd:broker05:6667/5]: broker05:6667/5:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1627884413.880|APIVERSION|rdkafka#consumer-1| [thrd:broker05:6667/5]: broker05:6667/5: Enabling feature SaslHandshake
%7|1627884413.880|APIVERSION|rdkafka#consumer-1| [thrd:broker05:6667/5]: broker05:6667/5:  Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker05:6667/5]: broker05:6667/5: Enabling feature LZ4
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker05:6667/5]: broker05:6667/5:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker05:6667/5]: broker05:6667/5: Enabling feature OffsetTime
%7|1627884413.881|FEATURE|rdkafka#consumer-1| [thrd:broker05:6667/5]: broker05:6667/5: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
%7|1627884413.881|STATE|rdkafka#consumer-1| [thrd:broker05:6667/5]: broker05:6667/5: Broker changed state APIVERSION_QUERY -> UP
%7|1627884413.881|BROADCAST|rdkafka#consumer-1| [thrd:broker05:6667/5]: Broadcasting state change
%7|1627884413.880|BRKMAIN|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Enter main broker thread
%7|1627884413.880|APIVERSION|rdkafka#consumer-1| [thrd:broker11:6667/11]: broker11:6667/11:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker11:6667/11]: broker11:6667/11: Enabling feature BrokerBalancedConsumer
%7|1627884413.880|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey LeaderAndIsr (4) Versions 0..4
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker11:6667/11]: broker11:6667/11:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey StopReplica (5) Versions 0..2
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey Unknown-6? (6) Versions 0..6
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker11:6667/11]: broker11:6667/11:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1627884413.880|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey CreateTopics (19) Versions 0..5
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey DeleteTopics (20) Versions 0..4
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey DeleteRecords (21) Versions 0..1
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey InitProducerId (22) Versions 0..3
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey EndTxn (26) Versions 0..1
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey DescribeAcls (29) Versions 0..2
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey CreateAcls (30) Versions 0..2
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey DeleteAcls (31) Versions 0..2
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey DescribeConfigs (32) Versions 0..2
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey AlterConfigs (33) Versions 0..1
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey Unknown-34? (34) Versions 0..1
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey Unknown-35? (35) Versions 0..1
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey Unknown-36? (36) Versions 0..2
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey Unknown-37? (37) Versions 0..2
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey Unknown-38? (38) Versions 0..2
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey Unknown-39? (39) Versions 0..2
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey Unknown-40? (40) Versions 0..2
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey Unknown-41? (41) Versions 0..2
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey Unknown-42? (42) Versions 0..2
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey Unknown-43? (43) Versions 0..2
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey Unknown-44? (44) Versions 0..1
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey Unknown-45? (45) Versions 0..0
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey Unknown-46? (46) Versions 0..0
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:   ApiKey Unknown-47? (47) Versions 0..0
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10: Enabling feature MsgVer1
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10: Enabling feature MsgVer2
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10: Enabling feature ApiVersion
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey Unknown-7? (7) Versions 0..3
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey OffsetCommit (8) Versions 0..8
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey OffsetFetch (9) Versions 0..7
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey GroupCoordinator (10) Versions 0..3
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey JoinGroup (11) Versions 0..7
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey Heartbeat (12) Versions 0..4
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey LeaveGroup (13) Versions 0..4
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey SyncGroup (14) Versions 0..5
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey DescribeGroups (15) Versions 0..5
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey ListGroups (16) Versions 0..3
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey SaslHandshake (17) Versions 0..1
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey ApiVersion (18) Versions 0..3
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey CreateTopics (19) Versions 0..5
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey DeleteTopics (20) Versions 0..4
%7|1627884413.880|BROADCAST|rdkafka#consumer-1| [thrd:broker08:6667/8]: Broadcasting state change
%7|1627884413.880|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey OffsetCommit (8) Versions 0..8
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey OffsetFetch (9) Versions 0..7
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey GroupCoordinator (10) Versions 0..3
%7|1627884413.880|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey LeaveGroup (13) Versions 0..4
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey SyncGroup (14) Versions 0..5
%7|1627884413.941|WAKEUPFD|rdkafka#consumer-1| [thrd:main]: broker01:6667/1: Enabled low-latency partition queue wake-ups
%7|1627884413.941|SEND|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8: Sent ApiVersionRequest (v0, 25 bytes @ 0, CorrId 1)
%7|1627884413.941|WAKEUPFD|rdkafka#consumer-1| [thrd:main]: broker01:6667/1: Enabled low-latency ops queue wake-ups
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
%7|1627884413.880|CONNECT|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12: Connected to ipv4#IP.203:6667
%7|1627884413.880|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4: Broker API support:
%7|1627884413.881|APIVERSION|rdkafka#consumer-1| [thrd:broker11:6667/11]: broker11:6667/11: Enabling feature ThrottleTime
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker11:6667/11]: broker11:6667/11:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker11:6667/11]: broker11:6667/11: Enabling feature Sasl
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker11:6667/11]: broker11:6667/11:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker11:6667/11]: broker11:6667/11: Enabling feature SaslHandshake
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker11:6667/11]: broker11:6667/11:  Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker11:6667/11]: broker11:6667/11: Enabling feature LZ4
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker11:6667/11]: broker11:6667/11:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker11:6667/11]: broker11:6667/11: Enabling feature OffsetTime
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey JoinGroup (11) Versions 0..7
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey Heartbeat (12) Versions 0..4
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey LeaveGroup (13) Versions 0..4
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey SyncGroup (14) Versions 0..5
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey DescribeGroups (15) Versions 0..5
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey ListGroups (16) Versions 0..3
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey SaslHandshake (17) Versions 0..1
%7|1627884413.880|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey SyncGroup (14) Versions 0..5
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10: Enabling feature BrokerGroupCoordinator
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Produce (0) Versions 0..8
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Fetch (1) Versions 0..11
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Offset (2) Versions 0..5
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Metadata (3) Versions 0..9
%7|1627884413.942|BROKER|rdkafka#consumer-1| [thrd:main]: broker01:6667/1: Added new broker with NodeId 1
%7|1627884413.942|FEATURE|rdkafka#consumer-1| [thrd:broker11:6667/11]: broker11:6667/11: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
%7|1627884413.942|METADATA|rdkafka#consumer-1| [thrd:broker05:6667/5]: Skipping metadata refresh of 1 topic(s): connected: already being requested
%7|1627884413.942|STATE|rdkafka#consumer-1| [thrd:broker11:6667/11]: broker11:6667/11: Broker changed state APIVERSION_QUERY -> UP
%7|1627884413.942|BROADCAST|rdkafka#consumer-1| [thrd:broker11:6667/11]: Broadcasting state change
%7|1627884413.942|METADATA|rdkafka#consumer-1| [thrd:broker11:6667/11]: Skipping metadata refresh of 1 topic(s): connected: already being requested
%7|1627884413.942|BRKMAIN|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Enter main broker thread
%7|1627884413.942|CONNECT|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: broker in state INIT connecting
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey DescribeGroups (15) Versions 0..5
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey ListGroups (16) Versions 0..3
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey SaslHandshake (17) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey ApiVersion (18) Versions 0..3
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey CreateTopics (19) Versions 0..5
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey DeleteTopics (20) Versions 0..4
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey DeleteRecords (21) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey InitProducerId (22) Versions 0..3
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey EndTxn (26) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey DescribeAcls (29) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey CreateAcls (30) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey DeleteAcls (31) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey DescribeConfigs (32) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey AlterConfigs (33) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey Unknown-34? (34) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey Unknown-35? (35) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey Unknown-36? (36) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey Unknown-37? (37) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey Unknown-38? (38) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey Unknown-39? (39) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey Unknown-40? (40) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey ApiVersion (18) Versions 0..3
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey Unknown-41? (41) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey Unknown-42? (42) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey Unknown-43? (43) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey Unknown-44? (44) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey Unknown-45? (45) Versions 0..0
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey Unknown-46? (46) Versions 0..0
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:   ApiKey Unknown-47? (47) Versions 0..0
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15: Enabling feature MsgVer1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1627884413.941|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey DeleteRecords (21) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey LeaderAndIsr (4) Versions 0..4
%7|1627884413.942|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Broker #14/16: broker06:6667 NodeId 6
%7|1627884413.942|RECV|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8: Received ApiVersionResponse (v0, 294 bytes, CorrId 1, rtt 0.34ms)
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8: Broker API support:
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Produce (0) Versions 0..8
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Fetch (1) Versions 0..11
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Offset (2) Versions 0..5
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Metadata (3) Versions 0..9
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey LeaderAndIsr (4) Versions 0..4
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey StopReplica (5) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Unknown-6? (6) Versions 0..6
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Unknown-7? (7) Versions 0..3
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey OffsetCommit (8) Versions 0..8
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey OffsetFetch (9) Versions 0..7
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey GroupCoordinator (10) Versions 0..3
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey JoinGroup (11) Versions 0..7
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Heartbeat (12) Versions 0..4
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey LeaveGroup (13) Versions 0..4
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey SyncGroup (14) Versions 0..5
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey DescribeGroups (15) Versions 0..5
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey ListGroups (16) Versions 0..3
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey SaslHandshake (17) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey ApiVersion (18) Versions 0..3
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey CreateTopics (19) Versions 0..5
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey DeleteTopics (20) Versions 0..4
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey DeleteRecords (21) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey InitProducerId (22) Versions 0..3
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey EndTxn (26) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey DescribeAcls (29) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey CreateAcls (30) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey DeleteAcls (31) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey DescribeConfigs (32) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey AlterConfigs (33) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Unknown-34? (34) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Unknown-35? (35) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Unknown-36? (36) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Unknown-37? (37) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Unknown-38? (38) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Unknown-39? (39) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Unknown-40? (40) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Unknown-41? (41) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Unknown-42? (42) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Unknown-43? (43) Versions 0..2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Unknown-44? (44) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Unknown-45? (45) Versions 0..0
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Unknown-46? (46) Versions 0..0
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:   ApiKey Unknown-47? (47) Versions 0..0
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8: Enabling feature MsgVer1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8: Enabling feature MsgVer2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8: Enabling feature ApiVersion
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8: Enabling feature BrokerGroupCoordinator
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8: Enabling feature BrokerBalancedConsumer
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8: Enabling feature ThrottleTime
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8: Enabling feature Sasl
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8: Enabling feature SaslHandshake
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:  Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8: Enabling feature LZ4
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15: Enabling feature MsgVer2
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15: Enabling feature ApiVersion
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15: Enabling feature BrokerGroupCoordinator
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15: Enabling feature BrokerBalancedConsumer
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15: Enabling feature ThrottleTime
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15: Enabling feature Sasl
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15: Enabling feature SaslHandshake
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:  Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15: Enabling feature LZ4
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15: Enabling feature OffsetTime
%7|1627884413.942|FEATURE|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
%7|1627884413.942|STATE|rdkafka#consumer-1| [thrd:broker15:6667/15]: broker15:6667/15: Broker changed state APIVERSION_QUERY -> UP
%7|1627884413.942|BROADCAST|rdkafka#consumer-1| [thrd:broker15:6667/15]: Broadcasting state change
%7|1627884413.880|RECV|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13: Received ApiVersionResponse (v0, 294 bytes, CorrId 1, rtt 0.01ms)
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13: Broker API support:
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Produce (0) Versions 0..8
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Fetch (1) Versions 0..11
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8: Enabling feature OffsetTime
%7|1627884413.943|FEATURE|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
%7|1627884413.943|STATE|rdkafka#consumer-1| [thrd:broker08:6667/8]: broker08:6667/8: Broker changed state APIVERSION_QUERY -> UP
%7|1627884413.943|BROADCAST|rdkafka#consumer-1| [thrd:broker08:6667/8]: Broadcasting state change
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey InitProducerId (22) Versions 0..3
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey StopReplica (5) Versions 0..2
%7|1627884413.881|CONNECT|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: broker in state INIT connecting
%7|1627884413.942|CONNECT|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Connecting to ipv4#IP.209:6667 (plaintext) with socket 45
%7|1627884413.943|STATE|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Broker changed state INIT -> CONNECT
%7|1627884413.943|BROADCAST|rdkafka#consumer-1| [thrd:broker01:6667/1]: Broadcasting state change
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey CreateTopics (19) Versions 0..5
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey DeleteTopics (20) Versions 0..4
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey DeleteRecords (21) Versions 0..1
%7|1627884413.943|CONNECT|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Connecting to ipv4#IP.201:6667 (plaintext) with socket 46
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1627884413.943|STATE|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Broker changed state INIT -> CONNECT
%7|1627884413.943|BROADCAST|rdkafka#consumer-1| [thrd:broker14:6667/14]: Broadcasting state change
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10: Enabling feature BrokerBalancedConsumer
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10: Enabling feature ThrottleTime
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10: Enabling feature Sasl
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Offset (2) Versions 0..5
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Metadata (3) Versions 0..9
%7|1627884413.943|CONNECT|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Connected to ipv4#IP.209:6667
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey LeaderAndIsr (4) Versions 0..4
%7|1627884413.941|CONNECTED|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12: Connected (#1)
%7|1627884413.943|FEATURE|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1627884413.943|STATE|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1627884413.943|BROADCAST|rdkafka#consumer-1| [thrd:broker12:6667/12]: Broadcasting state change
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey EndTxn (26) Versions 0..1
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey DescribeAcls (29) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey CreateAcls (30) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey DeleteAcls (31) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey DescribeConfigs (32) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey AlterConfigs (33) Versions 0..1
%7|1627884413.942|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey DescribeGroups (15) Versions 0..5
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey Unknown-34? (34) Versions 0..1
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey Unknown-35? (35) Versions 0..1
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey ListGroups (16) Versions 0..3
%7|1627884413.943|CONNECTED|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Connected (#1)
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Unknown-6? (6) Versions 0..6
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Unknown-7? (7) Versions 0..3
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey OffsetCommit (8) Versions 0..8
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey OffsetFetch (9) Versions 0..7
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey GroupCoordinator (10) Versions 0..3
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey JoinGroup (11) Versions 0..7
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Heartbeat (12) Versions 0..4
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey LeaveGroup (13) Versions 0..4
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey StopReplica (5) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Unknown-6? (6) Versions 0..6
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Unknown-7? (7) Versions 0..3
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey OffsetCommit (8) Versions 0..8
%7|1627884413.943|SEND|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12: Sent ApiVersionRequest (v0, 25 bytes @ 0, CorrId 1)
%7|1627884413.943|FEATURE|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1627884413.943|STATE|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1627884413.943|BROADCAST|rdkafka#consumer-1| [thrd:broker01:6667/1]: Broadcasting state change
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey SyncGroup (14) Versions 0..5
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey DescribeGroups (15) Versions 0..5
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey ListGroups (16) Versions 0..3
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey SaslHandshake (17) Versions 0..1
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey ApiVersion (18) Versions 0..3
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey CreateTopics (19) Versions 0..5
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey DeleteTopics (20) Versions 0..4
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey DeleteRecords (21) Versions 0..1
%7|1627884413.943|SEND|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Sent ApiVersionRequest (v0, 25 bytes @ 0, CorrId 1)
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10: Enabling feature SaslHandshake
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey Unknown-36? (36) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey SaslHandshake (17) Versions 0..1
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey ApiVersion (18) Versions 0..3
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey CreateTopics (19) Versions 0..5
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey InitProducerId (22) Versions 0..3
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey EndTxn (26) Versions 0..1
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey DescribeAcls (29) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey CreateAcls (30) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey DeleteAcls (31) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey DescribeConfigs (32) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey AlterConfigs (33) Versions 0..1
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Unknown-34? (34) Versions 0..1
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Unknown-35? (35) Versions 0..1
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Unknown-36? (36) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Unknown-37? (37) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Unknown-38? (38) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Unknown-39? (39) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Unknown-40? (40) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Unknown-41? (41) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Unknown-42? (42) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Unknown-43? (43) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Unknown-44? (44) Versions 0..1
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Unknown-45? (45) Versions 0..0
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Unknown-46? (46) Versions 0..0
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:   ApiKey Unknown-47? (47) Versions 0..0
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4: Enabling feature MsgVer1
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4: Enabling feature MsgVer2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4: Enabling feature ApiVersion
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
%7|1627884413.943|RECV|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12: Received ApiVersionResponse (v0, 294 bytes, CorrId 1, rtt 0.25ms)
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4: Enabling feature BrokerGroupCoordinator
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12: Broker API support:
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Produce (0) Versions 0..8
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Fetch (1) Versions 0..11
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Offset (2) Versions 0..5
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Metadata (3) Versions 0..9
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey LeaderAndIsr (4) Versions 0..4
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey DeleteTopics (20) Versions 0..4
%7|1627884413.943|CONNECT|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Connected to ipv4#IP.201:6667
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey Unknown-37? (37) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey Unknown-38? (38) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey Unknown-39? (39) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey DeleteRecords (21) Versions 0..1
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey InitProducerId (22) Versions 0..3
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey InitProducerId (22) Versions 0..3
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey OffsetFetch (9) Versions 0..7
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey Unknown-40? (40) Versions 0..2
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey EndTxn (26) Versions 0..1
%7|1627884413.943|CONNECTED|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Connected (#1)
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:  Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1627884413.944|FEATURE|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10: Enabling feature LZ4
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey StopReplica (5) Versions 0..2
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Unknown-6? (6) Versions 0..6
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10: Enabling feature OffsetTime
%7|1627884413.944|FEATURE|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
%7|1627884413.944|RECV|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Received ApiVersionResponse (v0, 294 bytes, CorrId 1, rtt 0.45ms)
%7|1627884413.944|STATE|rdkafka#consumer-1| [thrd:broker10:6667/10]: broker10:6667/10: Broker changed state APIVERSION_QUERY -> UP
%7|1627884413.944|BROADCAST|rdkafka#consumer-1| [thrd:broker10:6667/10]: Broadcasting state change
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey Unknown-41? (41) Versions 0..2
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey Unknown-42? (42) Versions 0..2
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey Unknown-43? (43) Versions 0..2
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey Unknown-44? (44) Versions 0..1
%7|1627884413.943|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Broker API support:
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Produce (0) Versions 0..8
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Fetch (1) Versions 0..11
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey DescribeAcls (29) Versions 0..2
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey CreateAcls (30) Versions 0..2
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey DeleteAcls (31) Versions 0..2
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey DescribeConfigs (32) Versions 0..2
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey AlterConfigs (33) Versions 0..1
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey Unknown-34? (34) Versions 0..1
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey Unknown-35? (35) Versions 0..1
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey Unknown-36? (36) Versions 0..2
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey Unknown-37? (37) Versions 0..2
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey Unknown-38? (38) Versions 0..2
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey Unknown-39? (39) Versions 0..2
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey Unknown-40? (40) Versions 0..2
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey Unknown-41? (41) Versions 0..2
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey Unknown-42? (42) Versions 0..2
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey Unknown-43? (43) Versions 0..2
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey Unknown-44? (44) Versions 0..1
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey Unknown-45? (45) Versions 0..0
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey Unknown-46? (46) Versions 0..0
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:   ApiKey Unknown-47? (47) Versions 0..0
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9: Enabling feature MsgVer1
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9: Enabling feature MsgVer2
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey GroupCoordinator (10) Versions 0..3
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey JoinGroup (11) Versions 0..7
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Heartbeat (12) Versions 0..4
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey LeaveGroup (13) Versions 0..4
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey SyncGroup (14) Versions 0..5
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey DescribeGroups (15) Versions 0..5
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey ListGroups (16) Versions 0..3
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey SaslHandshake (17) Versions 0..1
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey ApiVersion (18) Versions 0..3
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Offset (2) Versions 0..5
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Unknown-7? (7) Versions 0..3
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9: Enabling feature ApiVersion
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9: Enabling feature BrokerGroupCoordinator
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey CreateTopics (19) Versions 0..5
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey DeleteTopics (20) Versions 0..4
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey DeleteRecords (21) Versions 0..1
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey InitProducerId (22) Versions 0..3
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1627884413.944|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey Unknown-45? (45) Versions 0..0
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey Unknown-46? (46) Versions 0..0
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:   ApiKey Unknown-47? (47) Versions 0..0
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey EndTxn (26) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Metadata (3) Versions 0..9
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey DescribeAcls (29) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey CreateAcls (30) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey DeleteAcls (31) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey DescribeConfigs (32) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey AlterConfigs (33) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey Unknown-34? (34) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey Unknown-35? (35) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey Unknown-36? (36) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1627884413.944|STATE|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey LeaderAndIsr (4) Versions 0..4
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey StopReplica (5) Versions 0..2
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey OffsetCommit (8) Versions 0..8
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey OffsetFetch (9) Versions 0..7
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey GroupCoordinator (10) Versions 0..3
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey JoinGroup (11) Versions 0..7
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Heartbeat (12) Versions 0..4
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey EndTxn (26) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16: Enabling feature MsgVer1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1627884414.064|BROADCAST|rdkafka#consumer-1| [thrd:broker14:6667/14]: Broadcasting state change
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Unknown-6? (6) Versions 0..6
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Unknown-7? (7) Versions 0..3
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey OffsetCommit (8) Versions 0..8
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey OffsetFetch (9) Versions 0..7
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey GroupCoordinator (10) Versions 0..3
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey JoinGroup (11) Versions 0..7
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Heartbeat (12) Versions 0..4
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey LeaveGroup (13) Versions 0..4
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey SyncGroup (14) Versions 0..5
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey DescribeGroups (15) Versions 0..5
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey ListGroups (16) Versions 0..3
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey SaslHandshake (17) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey ApiVersion (18) Versions 0..3
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey CreateTopics (19) Versions 0..5
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey DeleteTopics (20) Versions 0..4
%7|1627884414.064|SEND|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Sent ApiVersionRequest (v0, 25 bytes @ 0, CorrId 1)
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey DeleteRecords (21) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey InitProducerId (22) Versions 0..3
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey EndTxn (26) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey Unknown-37? (37) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9: Enabling feature BrokerBalancedConsumer
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey DescribeAcls (29) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey CreateAcls (30) Versions 0..2
%7|1627884414.063|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4: Enabling feature BrokerBalancedConsumer
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4: Enabling feature ThrottleTime
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4: Enabling feature Sasl
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4: Enabling feature SaslHandshake
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:  Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4: Enabling feature LZ4
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4: Enabling feature OffsetTime
%7|1627884414.064|FEATURE|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
%7|1627884414.064|STATE|rdkafka#consumer-1| [thrd:broker04:6667/4]: broker04:6667/4: Broker changed state APIVERSION_QUERY -> UP
%7|1627884414.064|BROADCAST|rdkafka#consumer-1| [thrd:broker04:6667/4]: Broadcasting state change
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey LeaveGroup (13) Versions 0..4
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey SyncGroup (14) Versions 0..5
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey DescribeGroups (15) Versions 0..5
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey ListGroups (16) Versions 0..3
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey SaslHandshake (17) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey ApiVersion (18) Versions 0..3
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey CreateTopics (19) Versions 0..5
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey DeleteTopics (20) Versions 0..4
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey DeleteRecords (21) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey InitProducerId (22) Versions 0..3
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey EndTxn (26) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey DescribeAcls (29) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey CreateAcls (30) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey DeleteAcls (31) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey DescribeConfigs (32) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey AlterConfigs (33) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Unknown-34? (34) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Unknown-35? (35) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Unknown-36? (36) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Unknown-37? (37) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Unknown-38? (38) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Unknown-39? (39) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Unknown-40? (40) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Unknown-41? (41) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Unknown-42? (42) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Unknown-43? (43) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Unknown-44? (44) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Unknown-45? (45) Versions 0..0
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Unknown-46? (46) Versions 0..0
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:   ApiKey Unknown-47? (47) Versions 0..0
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12: Enabling feature MsgVer1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16: Enabling feature MsgVer2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16: Enabling feature ApiVersion
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16: Enabling feature BrokerGroupCoordinator
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16: Enabling feature BrokerBalancedConsumer
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16: Enabling feature ThrottleTime
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16: Enabling feature Sasl
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16: Enabling feature SaslHandshake
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:  Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16: Enabling feature LZ4
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1627884414.064|RECV|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Received ApiVersionResponse (v0, 294 bytes, CorrId 1, rtt 0.46ms)
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey DeleteAcls (31) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Broker API support:
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey DescribeConfigs (32) Versions 0..2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Produce (0) Versions 0..8
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey AlterConfigs (33) Versions 0..1
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16: Enabling feature OffsetTime
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Unknown-34? (34) Versions 0..1
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Unknown-35? (35) Versions 0..1
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Unknown-36? (36) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Unknown-37? (37) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Unknown-38? (38) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Unknown-39? (39) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Unknown-40? (40) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Unknown-41? (41) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Unknown-42? (42) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Unknown-43? (43) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Unknown-44? (44) Versions 0..1
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Unknown-45? (45) Versions 0..0
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey Unknown-38? (38) Versions 0..2
%7|1627884414.064|FEATURE|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12: Enabling feature MsgVer2
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9: Enabling feature ThrottleTime
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Unknown-46? (46) Versions 0..0
%7|1627884414.064|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Fetch (1) Versions 0..11
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Offset (2) Versions 0..5
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Metadata (3) Versions 0..9
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey LeaderAndIsr (4) Versions 0..4
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9: Enabling feature Sasl
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9: Enabling feature SaslHandshake
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey Unknown-39? (39) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey Unknown-40? (40) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey Unknown-41? (41) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:   ApiKey Unknown-47? (47) Versions 0..0
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12: Enabling feature ApiVersion
%7|1627884414.065|STATE|rdkafka#consumer-1| [thrd:broker16:6667/16]: broker16:6667/16: Broker changed state APIVERSION_QUERY -> UP
%7|1627884414.065|BROADCAST|rdkafka#consumer-1| [thrd:broker16:6667/16]: Broadcasting state change
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey StopReplica (5) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Unknown-6? (6) Versions 0..6
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Unknown-7? (7) Versions 0..3
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey OffsetCommit (8) Versions 0..8
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey OffsetFetch (9) Versions 0..7
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey GroupCoordinator (10) Versions 0..3
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey Unknown-42? (42) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey JoinGroup (11) Versions 0..7
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey Unknown-43? (43) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey DescribeAcls (29) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey CreateAcls (30) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey DeleteAcls (31) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey DescribeConfigs (32) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey AlterConfigs (33) Versions 0..1
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Unknown-34? (34) Versions 0..1
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Unknown-35? (35) Versions 0..1
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Unknown-36? (36) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Unknown-37? (37) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13: Enabling feature MsgVer1
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13: Enabling feature MsgVer2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13: Enabling feature ApiVersion
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Unknown-38? (38) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Unknown-39? (39) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Unknown-40? (40) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Unknown-41? (41) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Unknown-42? (42) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Unknown-43? (43) Versions 0..2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Unknown-44? (44) Versions 0..1
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Unknown-45? (45) Versions 0..0
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Unknown-46? (46) Versions 0..0
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:   ApiKey Unknown-47? (47) Versions 0..0
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Enabling feature MsgVer1
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Enabling feature MsgVer2
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Enabling feature ApiVersion
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13: Enabling feature BrokerGroupCoordinator
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey Unknown-44? (44) Versions 0..1
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12: Enabling feature BrokerGroupCoordinator
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12: Enabling feature BrokerBalancedConsumer
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12: Enabling feature ThrottleTime
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12: Enabling feature Sasl
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Heartbeat (12) Versions 0..4
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Enabling feature BrokerGroupCoordinator
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey Unknown-45? (45) Versions 0..0
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey Unknown-46? (46) Versions 0..0
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:   ApiKey Unknown-47? (47) Versions 0..0
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3: Enabling feature MsgVer1
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3: Enabling feature MsgVer2
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3: Enabling feature ApiVersion
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3: Enabling feature BrokerGroupCoordinator
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12: Enabling feature SaslHandshake
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:  Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12: Enabling feature LZ4
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12: Enabling feature OffsetTime
%7|1627884414.066|FEATURE|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
%7|1627884414.066|STATE|rdkafka#consumer-1| [thrd:broker12:6667/12]: broker12:6667/12: Broker changed state APIVERSION_QUERY -> UP
%7|1627884414.066|BROADCAST|rdkafka#consumer-1| [thrd:broker12:6667/12]: Broadcasting state change
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Enabling feature BrokerBalancedConsumer
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:  Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9: Enabling feature LZ4
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Enabling feature ThrottleTime
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1627884414.065|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey LeaveGroup (13) Versions 0..4
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey SyncGroup (14) Versions 0..5
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9: Enabling feature OffsetTime
%7|1627884414.066|FEATURE|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
%7|1627884414.066|STATE|rdkafka#consumer-1| [thrd:broker09:6667/9]: broker09:6667/9: Broker changed state APIVERSION_QUERY -> UP
%7|1627884414.066|BROADCAST|rdkafka#consumer-1| [thrd:broker09:6667/9]: Broadcasting state change
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey DescribeGroups (15) Versions 0..5
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey ListGroups (16) Versions 0..3
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey SaslHandshake (17) Versions 0..1
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey ApiVersion (18) Versions 0..3
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey CreateTopics (19) Versions 0..5
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey DeleteTopics (20) Versions 0..4
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey DeleteRecords (21) Versions 0..1
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey InitProducerId (22) Versions 0..3
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Enabling feature Sasl
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Enabling feature SaslHandshake
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:  Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Enabling feature LZ4
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Enabling feature OffsetTime
%7|1627884414.066|FEATURE|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
%7|1627884414.066|STATE|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Broker changed state APIVERSION_QUERY -> UP
%7|1627884414.066|BROADCAST|rdkafka#consumer-1| [thrd:broker01:6667/1]: Broadcasting state change
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey EndTxn (26) Versions 0..1
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13: Enabling feature BrokerBalancedConsumer
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3: Enabling feature BrokerBalancedConsumer
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3: Enabling feature ThrottleTime
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3: Enabling feature Sasl
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3: Enabling feature SaslHandshake
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:  Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13: Enabling feature ThrottleTime
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13: Enabling feature Sasl
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13: Enabling feature SaslHandshake
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:  Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13: Enabling feature LZ4
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13: Enabling feature OffsetTime
%7|1627884414.066|FEATURE|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3: Enabling feature LZ4
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3: Enabling feature OffsetTime
%7|1627884414.066|FEATURE|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
%7|1627884414.066|STATE|rdkafka#consumer-1| [thrd:broker03:6667/3]: broker03:6667/3: Broker changed state APIVERSION_QUERY -> UP
%7|1627884414.066|BROADCAST|rdkafka#consumer-1| [thrd:broker03:6667/3]: Broadcasting state change
%7|1627884414.066|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey DescribeAcls (29) Versions 0..2
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey CreateAcls (30) Versions 0..2
%7|1627884414.066|STATE|rdkafka#consumer-1| [thrd:broker13:6667/13]: broker13:6667/13: Broker changed state APIVERSION_QUERY -> UP
%7|1627884414.067|BROADCAST|rdkafka#consumer-1| [thrd:broker13:6667/13]: Broadcasting state change
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey DeleteAcls (31) Versions 0..2
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey DescribeConfigs (32) Versions 0..2
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey AlterConfigs (33) Versions 0..1
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Unknown-34? (34) Versions 0..1
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Unknown-35? (35) Versions 0..1
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Unknown-36? (36) Versions 0..2
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Unknown-37? (37) Versions 0..2
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Unknown-38? (38) Versions 0..2
%7|1627884414.067|WAKEUPFD|rdkafka#consumer-1| [thrd:main]: broker06:6667/6: Enabled low-latency partition queue wake-ups
%7|1627884414.067|WAKEUPFD|rdkafka#consumer-1| [thrd:main]: broker06:6667/6: Enabled low-latency ops queue wake-ups
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Unknown-39? (39) Versions 0..2
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Unknown-40? (40) Versions 0..2
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Unknown-41? (41) Versions 0..2
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Unknown-42? (42) Versions 0..2
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Unknown-43? (43) Versions 0..2
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Unknown-44? (44) Versions 0..1
%7|1627884414.067|BROKER|rdkafka#consumer-1| [thrd:main]: broker06:6667/6: Added new broker with NodeId 6
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Unknown-45? (45) Versions 0..0
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Unknown-46? (46) Versions 0..0
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:   ApiKey Unknown-47? (47) Versions 0..0
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1627884414.067|BRKMAIN|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Enter main broker thread
%7|1627884414.067|METADATA|rdkafka#consumer-1| [thrd:broker16:6667/16]: Skipping metadata refresh of 1 topic(s): connected: already being requested
%7|1627884414.067|METADATA|rdkafka#consumer-1| [thrd:broker04:6667/4]: Skipping metadata refresh of 1 topic(s): connected: already being requested
%7|1627884414.067|METADATA|rdkafka#consumer-1| [thrd:broker10:6667/10]: Skipping metadata refresh of 1 topic(s): connected: already being requested
%7|1627884414.067|METADATA|rdkafka#consumer-1| [thrd:broker01:6667/1]: Skipping metadata refresh of 1 topic(s): connected: already being requested
%7|1627884414.067|METADATA|rdkafka#consumer-1| [thrd:broker09:6667/9]: Skipping metadata refresh of 1 topic(s): connected: already being requested
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Enabling feature MsgVer1
%7|1627884414.067|METADATA|rdkafka#consumer-1| [thrd:broker08:6667/8]: Skipping metadata refresh of 1 topic(s): connected: already being requested
%7|1627884414.067|METADATA|rdkafka#consumer-1| [thrd:broker03:6667/3]: Skipping metadata refresh of 1 topic(s): connected: already being requested
%7|1627884414.067|METADATA|rdkafka#consumer-1| [thrd:broker15:6667/15]: Skipping metadata refresh of 1 topic(s): connected: already being requested
%7|1627884414.067|CONNECT|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: broker in state INIT connecting
%7|1627884414.067|CONNECT|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Connecting to ipv4#IP.214:6667 (plaintext) with socket 49
%7|1627884414.067|STATE|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Broker changed state INIT -> CONNECT
%7|1627884414.067|BROADCAST|rdkafka#consumer-1| [thrd:broker06:6667/6]: Broadcasting state change
%7|1627884414.067|METADATA|rdkafka#consumer-1| [thrd:broker13:6667/13]: Skipping metadata refresh of 1 topic(s): connected: already being requested
%7|1627884414.067|METADATA|rdkafka#consumer-1| [thrd:broker12:6667/12]: Skipping metadata refresh of 1 topic(s): connected: already being requested
%7|1627884414.067|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Broker #15/16: broker07:6667 NodeId 7
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Enabling feature MsgVer2
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Enabling feature ApiVersion
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Enabling feature BrokerGroupCoordinator
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Enabling feature BrokerBalancedConsumer
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Enabling feature ThrottleTime
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Enabling feature Sasl
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Enabling feature SaslHandshake
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:  Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Enabling feature LZ4
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1627884414.067|APIVERSION|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Enabling feature OffsetTime
%7|1627884414.067|FEATURE|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
%7|1627884414.067|STATE|rdkafka#consumer-1| [thrd:broker14:6667/14]: broker14:6667/14: Broker changed state APIVERSION_QUERY -> UP
%7|1627884414.067|BROADCAST|rdkafka#consumer-1| [thrd:broker14:6667/14]: Broadcasting state change
%7|1627884414.067|CONNECT|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Connected to ipv4#IP.214:6667
%7|1627884414.067|CONNECTED|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Connected (#1)
%7|1627884414.067|FEATURE|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1627884414.067|STATE|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1627884414.067|WAKEUPFD|rdkafka#consumer-1| [thrd:main]: broker07:6667/7: Enabled low-latency partition queue wake-ups
%7|1627884414.068|WAKEUPFD|rdkafka#consumer-1| [thrd:main]: broker07:6667/7: Enabled low-latency ops queue wake-ups
%7|1627884414.068|BROADCAST|rdkafka#consumer-1| [thrd:broker06:6667/6]: Broadcasting state change
%7|1627884414.068|SEND|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Sent ApiVersionRequest (v0, 25 bytes @ 0, CorrId 1)
%7|1627884414.068|BROKER|rdkafka#consumer-1| [thrd:main]: broker07:6667/7: Added new broker with NodeId 7
%7|1627884414.068|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Topic #0/1: TOPIC with 2 partitions
%7|1627884414.068|BRKMAIN|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Enter main broker thread
%7|1627884414.068|CONNECT|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: broker in state INIT connecting
%7|1627884414.068|STATE|rdkafka#consumer-1| [thrd:main]: Topic TOPIC changed state unknown -> exists
%7|1627884414.143|PARTCNT|rdkafka#consumer-1| [thrd:main]: Topic TOPIC partition count changed from 0 to 2
%7|1627884414.068|RECV|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Received ApiVersionResponse (v0, 294 bytes, CorrId 1, rtt 0.43ms)
%7|1627884414.143|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Broker API support:
%7|1627884414.143|TOPPARNEW|rdkafka#consumer-1| [thrd:main]: NEW TOPIC [0] 0x7efc4c00bc00 (at rd_kafka_topic_partition_cnt_update:550)
%7|1627884414.143|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Produce (0) Versions 0..8
%7|1627884414.143|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Fetch (1) Versions 0..11
%7|1627884414.143|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Offset (2) Versions 0..5
%7|1627884414.143|TOPPARNEW|rdkafka#consumer-1| [thrd:main]: NEW TOPIC [1] 0x7efc4c00c0a0 (at rd_kafka_topic_partition_cnt_update:550)
%7|1627884414.143|METADATA|rdkafka#consumer-1| [thrd:main]:   Topic TOPIC partition 0 Leader 1
%7|1627884414.143|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Metadata (3) Versions 0..9
%7|1627884414.143|BRKDELGT|rdkafka#consumer-1| [thrd:main]: TOPIC [0]: delegate to broker broker01:6667/1 (rktp 0x7efc4c00bc00, term 0, ref 2, remove 0)
%7|1627884414.143|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey LeaderAndIsr (4) Versions 0..4
%7|1627884414.143|BRKDELGT|rdkafka#consumer-1| [thrd:main]: TOPIC [0]: broker broker01:6667/1 is now leader for partition with 0 messages (0 bytes) queued
%7|1627884414.143|BRKMIGR|rdkafka#consumer-1| [thrd:main]: Migrating topic TOPIC [0] 0x7efc4c00bc00 from (none) to broker01:6667/1 (sending PARTITION_JOIN to broker01:6667/1)
%7|1627884414.143|CONNECT|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Connecting to ipv4#IP.207:6667 (plaintext) with socket 52
%7|1627884414.143|METADATA|rdkafka#consumer-1| [thrd:main]:   Topic TOPIC partition 1 Leader 2
%7|1627884414.143|BRKDELGT|rdkafka#consumer-1| [thrd:main]: TOPIC [1]: delegate to broker broker02:6667/2 (rktp 0x7efc4c00c0a0, term 0, ref 2, remove 0)
%7|1627884414.143|BRKDELGT|rdkafka#consumer-1| [thrd:main]: TOPIC [1]: broker broker02:6667/2 is now leader for partition with 0 messages (0 bytes) queued
%7|1627884414.143|BRKMIGR|rdkafka#consumer-1| [thrd:main]: Migrating topic TOPIC [1] 0x7efc4c00c0a0 from (none) to broker02:6667/2 (sending PARTITION_JOIN to broker02:6667/2)
%7|1627884414.143|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey StopReplica (5) Versions 0..2
%7|1627884414.143|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Unknown-6? (6) Versions 0..6
%7|1627884414.143|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2: 1/1 requested topic(s) seen in metadata
%7|1627884414.143|STATE|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Broker changed state INIT -> CONNECT
%7|1627884414.143|CLUSTERID|rdkafka#consumer-1| [thrd:main]: broker02:6667/2: ClusterId update "" -> "qbN-lGe2TFaYNyocAEOUDg"
%7|1627884414.143|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Unknown-7? (7) Versions 0..3
%7|1627884414.143|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey OffsetCommit (8) Versions 0..8
%7|1627884414.143|METADATA|rdkafka#consumer-1| [thrd:broker14:6667/14]: Skipping metadata refresh of 1 topic(s): connected: already being requested
%7|1627884414.143|BROADCAST|rdkafka#consumer-1| [thrd:broker07:6667/7]: Broadcasting state change
%7|1627884414.143|TOPBRK|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0]: joining broker (rktp 0x7efc4c00bc00)
%7|1627884414.143|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2: ===== Received metadata (for 1 requested topics): application requested =====
%7|1627884414.143|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey OffsetFetch (9) Versions 0..7
%7|1627884414.143|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey GroupCoordinator (10) Versions 0..3
%7|1627884414.143|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey JoinGroup (11) Versions 0..7
%7|1627884414.143|TOPBRK|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1]: joining broker (rktp 0x7efc4c00c0a0)
%7|1627884414.143|BROADCAST|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: Broadcasting state change
%7|1627884414.143|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Heartbeat (12) Versions 0..4
%7|1627884414.143|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey LeaveGroup (13) Versions 0..4
%7|1627884414.143|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey SyncGroup (14) Versions 0..5
%7|1627884414.143|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2: ClusterId: qbN-lGe2TFaYNyocAEOUDg, ControllerId: 1
%7|1627884414.143|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey DescribeGroups (15) Versions 0..5
%7|1627884414.143|CONNECT|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Connected to ipv4#IP.207:6667
%7|1627884414.143|BROADCAST|rdkafka#consumer-1| [thrd:broker01:6667/1]: Broadcasting state change
%7|1627884414.143|CONNECTED|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Connected (#1)
%7|1627884414.144|FEATURE|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1627884414.144|STATE|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1627884414.144|BROADCAST|rdkafka#consumer-1| [thrd:broker07:6667/7]: Broadcasting state change
%7|1627884414.143|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey ListGroups (16) Versions 0..3
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey SaslHandshake (17) Versions 0..1
%7|1627884414.143|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2: 16 brokers, 1 topics
%7|1627884414.144|SEND|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Sent ApiVersionRequest (v0, 25 bytes @ 0, CorrId 1)
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Broker #0/16: broker05:6667 NodeId 5
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Broker #1/16: broker10:6667 NodeId 10
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Broker #2/16: broker15:6667 NodeId 15
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Broker #3/16: broker09:6667 NodeId 9
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey ApiVersion (18) Versions 0..3
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Broker #4/16: broker11:6667 NodeId 11
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Broker #5/16: broker04:6667 NodeId 4
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey CreateTopics (19) Versions 0..5
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey DeleteTopics (20) Versions 0..4
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey DeleteRecords (21) Versions 0..1
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey InitProducerId (22) Versions 0..3
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey EndTxn (26) Versions 0..1
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Broker #6/16: broker16:6667 NodeId 16
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Broker #7/16: broker03:6667 NodeId 3
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey DescribeAcls (29) Versions 0..2
%7|1627884414.144|RECV|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Received ApiVersionResponse (v0, 294 bytes, CorrId 1, rtt 0.23ms)
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey CreateAcls (30) Versions 0..2
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Broker API support:
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Produce (0) Versions 0..8
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Fetch (1) Versions 0..11
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Offset (2) Versions 0..5
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Metadata (3) Versions 0..9
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey LeaderAndIsr (4) Versions 0..4
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey StopReplica (5) Versions 0..2
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey DeleteAcls (31) Versions 0..2
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey DescribeConfigs (32) Versions 0..2
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey AlterConfigs (33) Versions 0..1
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Unknown-6? (6) Versions 0..6
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Unknown-7? (7) Versions 0..3
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Broker #8/16: broker13:6667 NodeId 13
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Broker #9/16: broker02:6667 NodeId 2
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Broker #10/16: broker08:6667 NodeId 8
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Broker #11/16: broker12:6667 NodeId 12
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Unknown-34? (34) Versions 0..1
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Unknown-35? (35) Versions 0..1
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Unknown-36? (36) Versions 0..2
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Unknown-37? (37) Versions 0..2
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Broker #12/16: broker14:6667 NodeId 14
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Unknown-38? (38) Versions 0..2
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Broker #13/16: broker01:6667 NodeId 1
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Broker #14/16: broker06:6667 NodeId 6
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Broker #15/16: broker07:6667 NodeId 7
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey OffsetCommit (8) Versions 0..8
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Unknown-39? (39) Versions 0..2
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey OffsetFetch (9) Versions 0..7
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey GroupCoordinator (10) Versions 0..3
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey JoinGroup (11) Versions 0..7
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Heartbeat (12) Versions 0..4
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey LeaveGroup (13) Versions 0..4
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey SyncGroup (14) Versions 0..5
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Unknown-40? (40) Versions 0..2
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Unknown-41? (41) Versions 0..2
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Unknown-42? (42) Versions 0..2
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Unknown-43? (43) Versions 0..2
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Unknown-44? (44) Versions 0..1
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2:   Topic #0/1: TOPIC with 2 partitions
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Unknown-45? (45) Versions 0..0
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Unknown-46? (46) Versions 0..0
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:   ApiKey Unknown-47? (47) Versions 0..0
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]:   Topic TOPIC partition 0 Leader 1
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]:   Topic TOPIC partition 1 Leader 2
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Enabling feature MsgVer1
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Enabling feature MsgVer2
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Enabling feature ApiVersion
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Enabling feature BrokerGroupCoordinator
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Enabling feature BrokerBalancedConsumer
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Enabling feature ThrottleTime
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Enabling feature Sasl
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Enabling feature SaslHandshake
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:  Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Enabling feature LZ4
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Enabling feature OffsetTime
%7|1627884414.144|METADATA|rdkafka#consumer-1| [thrd:main]: broker02:6667/2: 1/1 requested topic(s) seen in metadata
%7|1627884414.144|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey DescribeGroups (15) Versions 0..5
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey ListGroups (16) Versions 0..3
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey SaslHandshake (17) Versions 0..1
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey ApiVersion (18) Versions 0..3
%7|1627884414.145|DESP|rdkafka#consumer-1| [thrd:app]: Setting topic TOPIC [0] partition as desired
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey CreateTopics (19) Versions 0..5
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey DeleteTopics (20) Versions 0..4
%7|1627884414.145|FEATURE|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
%7|1627884414.145|STATE|rdkafka#consumer-1| [thrd:broker06:6667/6]: broker06:6667/6: Broker changed state APIVERSION_QUERY -> UP
%7|1627884414.145|BROADCAST|rdkafka#consumer-1| [thrd:broker06:6667/6]: Broadcasting state change
%7|1627884414.145|METADATA|rdkafka#consumer-1| [thrd:broker06:6667/6]: Skipping metadata refresh of 1 topic(s): connected: already being requested
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey DeleteRecords (21) Versions 0..1
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey InitProducerId (22) Versions 0..3
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1627884414.145|BARRIER|rdkafka#consumer-1| [thrd:app]: TOPIC [0]: rd_kafka_toppar_op_fetch_start:2139: new version barrier v2
%7|1627884414.145|CONSUMER|rdkafka#consumer-1| [thrd:app]: Start consuming TOPIC [0] at offset BEGINNING (v2)
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey EndTxn (26) Versions 0..1
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey DescribeAcls (29) Versions 0..2
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey CreateAcls (30) Versions 0..2
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey DeleteAcls (31) Versions 0..2
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey DescribeConfigs (32) Versions 0..2
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey AlterConfigs (33) Versions 0..1
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Unknown-34? (34) Versions 0..1
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Unknown-35? (35) Versions 0..1
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Unknown-36? (36) Versions 0..2
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Unknown-37? (37) Versions 0..2
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Unknown-38? (38) Versions 0..2
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Unknown-39? (39) Versions 0..2
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Unknown-40? (40) Versions 0..2
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Unknown-41? (41) Versions 0..2
%7|1627884414.145|OP|rdkafka#consumer-1| [thrd:main]: TOPIC [0] received op FETCH_START (v2) in fetch-state none (opv1)
%7|1627884414.145|FETCH|rdkafka#consumer-1| [thrd:main]: Start fetch for TOPIC [0] in state none at offset BEGINNING (v2)
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Unknown-42? (42) Versions 0..2
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Unknown-43? (43) Versions 0..2
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Unknown-44? (44) Versions 0..1
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Unknown-45? (45) Versions 0..0
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Unknown-46? (46) Versions 0..0
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:   ApiKey Unknown-47? (47) Versions 0..0
%7|1627884414.145|DESP|rdkafka#consumer-1| [thrd:app]: Setting topic TOPIC [1] partition as desired
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Enabling feature MsgVer1
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Enabling feature MsgVer2
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Enabling feature ApiVersion
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
%7|1627884414.145|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition TOPIC [0] changed fetch state none -> offset-query
%7|1627884414.145|OFFSET|rdkafka#consumer-1| [thrd:main]: TOPIC [0]: offset reset (at offset BEGINNING) to BEGINNING: update: Success
%7|1627884414.145|OFFREQ|rdkafka#consumer-1| [thrd:main]: broker01:6667/1: Partition TOPIC [0]: querying for logical offset BEGINNING (opv 2)
%7|1627884414.145|OFFSET|rdkafka#consumer-1| [thrd:main]: broker01:6667/1: OffsetRequest (v0, opv 0) for 1 topic(s) and 1 partition(s)
%7|1627884414.145|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition TOPIC [0] changed fetch state offset-query -> offset-wait
%7|1627884414.145|BARRIER|rdkafka#consumer-1| [thrd:app]: TOPIC [1]: rd_kafka_toppar_op_fetch_start:2139: new version barrier v2
%7|1627884414.145|CONSUMER|rdkafka#consumer-1| [thrd:app]: Start consuming TOPIC [1] at offset BEGINNING (v2)
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Enabling feature BrokerGroupCoordinator
%7|1627884414.145|SEND|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Sent OffsetRequest (v0, 71 bytes @ 0, CorrId 2)
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1627884414.145|OP|rdkafka#consumer-1| [thrd:main]: TOPIC [1] received op FETCH_START (v2) in fetch-state none (opv1)
%7|1627884414.145|FETCH|rdkafka#consumer-1| [thrd:main]: Start fetch for TOPIC [1] in state none at offset BEGINNING (v2)
%7|1627884414.146|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition TOPIC [1] changed fetch state none -> offset-query
%7|1627884414.146|OFFSET|rdkafka#consumer-1| [thrd:main]: TOPIC [1]: offset reset (at offset BEGINNING) to BEGINNING: update: Success
%7|1627884414.146|OFFREQ|rdkafka#consumer-1| [thrd:main]: broker02:6667/2: Partition TOPIC [1]: querying for logical offset BEGINNING (opv 2)
%7|1627884414.145|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1627884414.146|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1627884414.146|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1627884414.146|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1627884414.146|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Enabling feature BrokerBalancedConsumer
%7|1627884414.146|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1627884414.146|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1627884414.146|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Enabling feature ThrottleTime
%7|1627884414.146|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1627884414.146|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Enabling feature Sasl
%7|1627884414.146|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1627884414.146|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Enabling feature SaslHandshake
%7|1627884414.146|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:  Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1627884414.146|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Enabling feature LZ4
%7|1627884414.146|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1627884414.146|APIVERSION|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Enabling feature OffsetTime
%7|1627884414.146|OFFSET|rdkafka#consumer-1| [thrd:main]: broker02:6667/2: OffsetRequest (v0, opv 0) for 1 topic(s) and 1 partition(s)
%7|1627884414.146|FEATURE|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
%7|1627884414.146|STATE|rdkafka#consumer-1| [thrd:broker07:6667/7]: broker07:6667/7: Broker changed state APIVERSION_QUERY -> UP
%7|1627884414.146|BROADCAST|rdkafka#consumer-1| [thrd:broker07:6667/7]: Broadcasting state change
%7|1627884414.146|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition TOPIC [1] changed fetch state offset-query -> offset-wait
%7|1627884414.146|METADATA|rdkafka#consumer-1| [thrd:broker07:6667/7]: Skipping metadata refresh of 1 topic(s): connected: already being requested
%7|1627884414.146|SEND|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Sent OffsetRequest (v0, 71 bytes @ 0, CorrId 4)
%7|1627884414.147|RECV|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Received OffsetResponse (v0, 48 bytes, CorrId 4, rtt 0.88ms)
%7|1627884414.147|OFFSET|rdkafka#consumer-1| [thrd:main]: broker02:6667/2: Offset reply for topic TOPIC [1] (v2 vs v2)
%7|1627884414.147|OFFSET|rdkafka#consumer-1| [thrd:main]: Offset BEGINNING request for TOPIC [1] returned offset 275425955 (275425955)
%7|1627884414.147|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition TOPIC [1] changed fetch state offset-wait -> active
%7|1627884414.147|FETCH|rdkafka#consumer-1| [thrd:main]: Partition TOPIC [1] start fetching at offset 275425955
%7|1627884414.147|WAKEUP|rdkafka#consumer-1| [thrd:main]: broker02:6667/2: Wake-up
%7|1627884414.147|FETCHDEC|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: Topic TOPIC [1]: fetch decide: updating to version 2 (was 0) at offset 275425955 (was 0)
%7|1627884414.147|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] in state active at offset 275425955 (0/100000 msgs, 0/1048576 kb queued, opv 2) is fetchable:
%7|1627884414.147|FETCHADD|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Added TOPIC [1] to fetch list (1 entries, opv 2)
%7|1627884414.147|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch topic TOPIC [1] at offset 275425955 (v2)
%7|1627884414.147|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch 1/1/1 toppar(s)
%7|1627884414.147|SEND|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Sent FetchRequest (v4, 84 bytes @ 0, CorrId 5)
%7|1627884414.155|RECV|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Received FetchResponse (v4, 1048640 bytes, CorrId 5, rtt 8.52ms)
%7|1627884414.155|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] MessageSet size 1048576, error "Success", MaxOffset 281557208, Ver 2/2
%7|1627884414.155|MSG|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Skip offset 275425892 < fetch_offset 275425955
%7|1627884414.155|MSG|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Skip offset 275425897 < fetch_offset 275425955
%7|1627884414.155|PROTOUFLOW|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Protocol read buffer underflow at 173/574 (rd_kafka_msgset_reader_msg_v2:674): expected 18446744073709551597 bytes > 401 remaining bytes (truncated response from broker (ok))
%7|1627884414.155|CONSUME|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1]: Increasing max fetch bytes to 2097152
%7|1627884414.155|CONSUME|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Enqueue 0 message(s) (0 ops) on TOPIC [1] fetch queue (qlen 0, v2, last_offset -1)
%7|1627884414.156|BACKOFF|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Fetch backoff for 500ms: Local: Read underflow
%7|1627884414.156|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] in state active at offset 275425955 (0/100000 msgs, 0/1048576 kb queued, opv 2) is not fetchable: fetch backed off
%7|1627884414.156|FETCHADD|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Removed TOPIC [1] from fetch list (0 entries, opv 2)
%7|1627884414.156|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 499ms
%7|1627884414.162|RECV|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Received OffsetResponse (v0, 48 bytes, CorrId 2, rtt 16.40ms)
%7|1627884414.162|OFFSET|rdkafka#consumer-1| [thrd:main]: broker01:6667/1: Offset reply for topic TOPIC [0] (v2 vs v2)
%7|1627884414.162|OFFSET|rdkafka#consumer-1| [thrd:main]: Offset BEGINNING request for TOPIC [0] returned offset 275431358 (275431358)
%7|1627884414.162|PARTSTATE|rdkafka#consumer-1| [thrd:main]: Partition TOPIC [0] changed fetch state offset-wait -> active
%7|1627884414.162|FETCH|rdkafka#consumer-1| [thrd:main]: Partition TOPIC [0] start fetching at offset 275431358
%7|1627884414.162|WAKEUP|rdkafka#consumer-1| [thrd:main]: broker01:6667/1: Wake-up
%7|1627884414.162|FETCHDEC|rdkafka#consumer-1| [thrd:broker01:6667/1]: Topic TOPIC [0]: fetch decide: updating to version 2 (was 0) at offset 275431358 (was 0)
%7|1627884414.162|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] in state active at offset 275431358 (0/100000 msgs, 0/1048576 kb queued, opv 2) is fetchable:
%7|1627884414.162|FETCHADD|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Added TOPIC [0] to fetch list (1 entries, opv 2)
%7|1627884414.162|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch topic TOPIC [0] at offset 275431358 (v2)
%7|1627884414.162|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch 1/1/1 toppar(s)
%7|1627884414.162|SEND|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Sent FetchRequest (v4, 84 bytes @ 0, CorrId 3)
%7|1627884414.166|RECV|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Received FetchResponse (v4, 1048640 bytes, CorrId 3, rtt 4.09ms)
%7|1627884414.166|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] MessageSet size 1048576, error "Success", MaxOffset 281565554, Ver 2/2
%7|1627884414.166|MSG|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Skip offset 275431295 < fetch_offset 275431358
%7|1627884414.166|MSG|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Skip offset 275431300 < fetch_offset 275431358
%7|1627884414.166|PROTOUFLOW|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Protocol read buffer underflow at 173/576 (rd_kafka_msgset_reader_msg_v2:674): expected 18446744073709551597 bytes > 403 remaining bytes (truncated response from broker (ok))
%7|1627884414.166|CONSUME|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0]: Increasing max fetch bytes to 2097152
%7|1627884414.166|CONSUME|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Enqueue 0 message(s) (0 ops) on TOPIC [0] fetch queue (qlen 0, v2, last_offset -1)
%7|1627884414.166|BACKOFF|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Fetch backoff for 500ms: Local: Read underflow
%7|1627884414.166|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] in state active at offset 275431358 (0/100000 msgs, 0/1048576 kb queued, opv 2) is not fetchable: fetch backed off
%7|1627884414.166|FETCHADD|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Removed TOPIC [0] from fetch list (0 entries, opv 2)
%7|1627884414.166|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 499ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.655|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884414.656|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] in state active at offset 275425955 (0/100000 msgs, 0/1048576 kb queued, opv 2) is fetchable:
%7|1627884414.656|FETCHADD|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Added TOPIC [1] to fetch list (1 entries, opv 2)
%7|1627884414.656|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch topic TOPIC [1] at offset 275425955 (v2)
%7|1627884414.656|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch 1/1/1 toppar(s)
%7|1627884414.656|SEND|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Sent FetchRequest (v4, 84 bytes @ 0, CorrId 6)
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] in state active at offset 275431358 (0/100000 msgs, 0/1048576 kb queued, opv 2) is fetchable:
%7|1627884414.666|FETCHADD|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Added TOPIC [0] to fetch list (1 entries, opv 2)
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch topic TOPIC [0] at offset 275431358 (v2)
%7|1627884414.666|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch 1/1/1 toppar(s)
%7|1627884414.666|SEND|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Sent FetchRequest (v4, 84 bytes @ 0, CorrId 4)
%7|1627884414.671|RECV|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Received FetchResponse (v4, 2097216 bytes, CorrId 6, rtt 15.48ms)
%7|1627884414.671|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] MessageSet size 2097152, error "Success", MaxOffset 281557221, Ver 2/2
%7|1627884414.671|MSG|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Skip offset 275425892 < fetch_offset 275425955
%7|1627884414.671|MSG|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Skip offset 275425897 < fetch_offset 275425955
%7|1627884414.671|PROTOUFLOW|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Protocol read buffer underflow at 173/574 (rd_kafka_msgset_reader_msg_v2:674): expected 18446744073709551597 bytes > 401 remaining bytes (truncated response from broker (ok))
%7|1627884414.671|CONSUME|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1]: Increasing max fetch bytes to 4194304
%7|1627884414.671|CONSUME|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Enqueue 0 message(s) (0 ops) on TOPIC [1] fetch queue (qlen 0, v2, last_offset -1)
%7|1627884414.671|BACKOFF|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Fetch backoff for 500ms: Local: Read underflow
%7|1627884414.672|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] in state active at offset 275425955 (0/100000 msgs, 0/1048576 kb queued, opv 2) is not fetchable: fetch backed off
%7|1627884414.672|FETCHADD|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Removed TOPIC [1] from fetch list (0 entries, opv 2)
%7|1627884414.672|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 499ms
%7|1627884414.672|RECV|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Received FetchResponse (v4, 2097216 bytes, CorrId 4, rtt 5.95ms)
%7|1627884414.672|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] MessageSet size 2097152, error "Success", MaxOffset 281565566, Ver 2/2
%7|1627884414.672|MSG|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Skip offset 275431295 < fetch_offset 275431358
%7|1627884414.672|MSG|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Skip offset 275431300 < fetch_offset 275431358
%7|1627884414.672|PROTOUFLOW|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Protocol read buffer underflow at 173/576 (rd_kafka_msgset_reader_msg_v2:674): expected 18446744073709551597 bytes > 403 remaining bytes (truncated response from broker (ok))
%7|1627884414.672|CONSUME|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0]: Increasing max fetch bytes to 4194304
%7|1627884414.672|CONSUME|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Enqueue 0 message(s) (0 ops) on TOPIC [0] fetch queue (qlen 0, v2, last_offset -1)
%7|1627884414.672|BACKOFF|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Fetch backoff for 500ms: Local: Read underflow
%7|1627884414.673|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] in state active at offset 275431358 (0/100000 msgs, 0/1048576 kb queued, opv 2) is not fetchable: fetch backed off
%7|1627884414.673|FETCHADD|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Removed TOPIC [0] from fetch list (0 entries, opv 2)
%7|1627884414.673|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 499ms
%7|1627884415.171|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884415.171|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884415.171|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884415.171|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884415.171|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884415.171|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884415.171|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884415.171|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884415.171|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884415.171|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884415.171|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884415.171|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884415.171|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 0ms
%7|1627884415.171|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] in state active at offset 275425955 (0/100000 msgs, 0/1048576 kb queued, opv 2) is fetchable:
%7|1627884415.171|FETCHADD|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Added TOPIC [1] to fetch list (1 entries, opv 2)
%7|1627884415.171|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch topic TOPIC [1] at offset 275425955 (v2)
%7|1627884415.171|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch 1/1/1 toppar(s)
%7|1627884415.171|SEND|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Sent FetchRequest (v4, 84 bytes @ 0, CorrId 7)
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.172|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 0ms
%7|1627884415.173|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] in state active at offset 275431358 (0/100000 msgs, 0/1048576 kb queued, opv 2) is fetchable:
%7|1627884415.173|FETCHADD|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Added TOPIC [0] to fetch list (1 entries, opv 2)
%7|1627884415.173|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch topic TOPIC [0] at offset 275431358 (v2)
%7|1627884415.173|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch 1/1/1 toppar(s)
%7|1627884415.173|SEND|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Sent FetchRequest (v4, 84 bytes @ 0, CorrId 5)
%7|1627884415.186|RECV|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Received FetchResponse (v4, 4194368 bytes, CorrId 5, rtt 12.92ms)
%7|1627884415.186|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] MessageSet size 4194304, error "Success", MaxOffset 281565577, Ver 2/2
%7|1627884415.186|MSG|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Skip offset 275431295 < fetch_offset 275431358
%7|1627884415.186|MSG|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Skip offset 275431300 < fetch_offset 275431358
%7|1627884415.186|PROTOUFLOW|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Protocol read buffer underflow at 173/576 (rd_kafka_msgset_reader_msg_v2:674): expected 18446744073709551597 bytes > 403 remaining bytes (truncated response from broker (ok))
%7|1627884415.186|CONSUME|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0]: Increasing max fetch bytes to 8388608
%7|1627884415.186|CONSUME|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Enqueue 0 message(s) (0 ops) on TOPIC [0] fetch queue (qlen 0, v2, last_offset -1)
%7|1627884415.186|BACKOFF|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Fetch backoff for 500ms: Local: Read underflow
%7|1627884415.186|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] in state active at offset 275431358 (0/100000 msgs, 0/1048576 kb queued, opv 2) is not fetchable: fetch backed off
%7|1627884415.186|FETCHADD|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Removed TOPIC [0] from fetch list (0 entries, opv 2)
%7|1627884415.186|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 499ms
%7|1627884415.196|RECV|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Received FetchResponse (v4, 4194368 bytes, CorrId 7, rtt 24.86ms)
%7|1627884415.196|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] MessageSet size 4194304, error "Success", MaxOffset 281557231, Ver 2/2
%7|1627884415.196|MSG|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Skip offset 275425892 < fetch_offset 275425955
%7|1627884415.196|MSG|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Skip offset 275425897 < fetch_offset 275425955
%7|1627884415.196|PROTOUFLOW|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Protocol read buffer underflow at 173/574 (rd_kafka_msgset_reader_msg_v2:674): expected 18446744073709551597 bytes > 401 remaining bytes (truncated response from broker (ok))
%7|1627884415.196|CONSUME|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1]: Increasing max fetch bytes to 8388608
%7|1627884415.196|CONSUME|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Enqueue 0 message(s) (0 ops) on TOPIC [1] fetch queue (qlen 0, v2, last_offset -1)
%7|1627884415.196|BACKOFF|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Fetch backoff for 500ms: Local: Read underflow
%7|1627884415.197|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] in state active at offset 275425955 (0/100000 msgs, 0/1048576 kb queued, opv 2) is not fetchable: fetch backed off
%7|1627884415.197|FETCHADD|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Removed TOPIC [1] from fetch list (0 entries, opv 2)
%7|1627884415.197|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 499ms
%7|1627884415.686|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] in state active at offset 275431358 (0/100000 msgs, 0/1048576 kb queued, opv 2) is fetchable:
%7|1627884415.686|FETCHADD|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Added TOPIC [0] to fetch list (1 entries, opv 2)
%7|1627884415.686|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch topic TOPIC [0] at offset 275431358 (v2)
%7|1627884415.686|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch 1/1/1 toppar(s)
%7|1627884415.686|SEND|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Sent FetchRequest (v4, 84 bytes @ 0, CorrId 6)
%7|1627884415.696|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] in state active at offset 275425955 (0/100000 msgs, 0/1048576 kb queued, opv 2) is fetchable:
%7|1627884415.696|FETCHADD|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Added TOPIC [1] to fetch list (1 entries, opv 2)
%7|1627884415.696|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch topic TOPIC [1] at offset 275425955 (v2)
%7|1627884415.696|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch 1/1/1 toppar(s)
%7|1627884415.696|SEND|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Sent FetchRequest (v4, 84 bytes @ 0, CorrId 8)
%7|1627884415.706|RECV|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Received FetchResponse (v4, 8388672 bytes, CorrId 6, rtt 20.14ms)
%7|1627884415.706|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] MessageSet size 8388608, error "Success", MaxOffset 281565595, Ver 2/2
%7|1627884415.706|MSG|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Skip offset 275431295 < fetch_offset 275431358
%7|1627884415.706|MSG|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Skip offset 275431300 < fetch_offset 275431358
%7|1627884415.706|PROTOUFLOW|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Protocol read buffer underflow at 173/576 (rd_kafka_msgset_reader_msg_v2:674): expected 18446744073709551597 bytes > 403 remaining bytes (truncated response from broker (ok))
%7|1627884415.706|CONSUME|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0]: Increasing max fetch bytes to 16777216
%7|1627884415.706|CONSUME|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Enqueue 0 message(s) (0 ops) on TOPIC [0] fetch queue (qlen 0, v2, last_offset -1)
%7|1627884415.706|BACKOFF|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Fetch backoff for 500ms: Local: Read underflow
%7|1627884415.707|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] in state active at offset 275431358 (0/100000 msgs, 0/1048576 kb queued, opv 2) is not fetchable: fetch backed off
%7|1627884415.707|FETCHADD|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Removed TOPIC [0] from fetch list (0 entries, opv 2)
%7|1627884415.707|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 499ms
%7|1627884415.724|RECV|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Received FetchResponse (v4, 8388672 bytes, CorrId 8, rtt 27.24ms)
%7|1627884415.724|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] MessageSet size 8388608, error "Success", MaxOffset 281557251, Ver 2/2
%7|1627884415.724|MSG|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Skip offset 275425892 < fetch_offset 275425955
%7|1627884415.724|MSG|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Skip offset 275425897 < fetch_offset 275425955
%7|1627884415.724|PROTOUFLOW|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Protocol read buffer underflow at 173/574 (rd_kafka_msgset_reader_msg_v2:674): expected 18446744073709551597 bytes > 401 remaining bytes (truncated response from broker (ok))
%7|1627884415.724|CONSUME|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1]: Increasing max fetch bytes to 16777216
%7|1627884415.724|CONSUME|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Enqueue 0 message(s) (0 ops) on TOPIC [1] fetch queue (qlen 0, v2, last_offset -1)
%7|1627884415.724|BACKOFF|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Fetch backoff for 500ms: Local: Read underflow
%7|1627884415.725|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] in state active at offset 275425955 (0/100000 msgs, 0/1048576 kb queued, opv 2) is not fetchable: fetch backed off
%7|1627884415.725|FETCHADD|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Removed TOPIC [1] from fetch list (0 entries, opv 2)
%7|1627884415.725|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 499ms
%7|1627884416.206|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] in state active at offset 275431358 (0/100000 msgs, 0/1048576 kb queued, opv 2) is fetchable:
%7|1627884416.207|FETCHADD|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Added TOPIC [0] to fetch list (1 entries, opv 2)
%7|1627884416.207|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch topic TOPIC [0] at offset 275431358 (v2)
%7|1627884416.207|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch 1/1/1 toppar(s)
%7|1627884416.207|SEND|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Sent FetchRequest (v4, 84 bytes @ 0, CorrId 7)
%7|1627884416.224|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] in state active at offset 275425955 (0/100000 msgs, 0/1048576 kb queued, opv 2) is fetchable:
%7|1627884416.224|FETCHADD|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Added TOPIC [1] to fetch list (1 entries, opv 2)
%7|1627884416.224|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch topic TOPIC [1] at offset 275425955 (v2)
%7|1627884416.224|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch 1/1/1 toppar(s)
%7|1627884416.224|SEND|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Sent FetchRequest (v4, 84 bytes @ 0, CorrId 9)
%7|1627884416.243|RECV|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Received FetchResponse (v4, 16777280 bytes, CorrId 7, rtt 36.35ms)
%7|1627884416.243|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] MessageSet size 16777216, error "Success", MaxOffset 281565611, Ver 2/2
%7|1627884416.243|MSG|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Skip offset 275431295 < fetch_offset 275431358
%7|1627884416.243|MSG|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Skip offset 275431300 < fetch_offset 275431358
%7|1627884416.243|PROTOUFLOW|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Protocol read buffer underflow at 173/576 (rd_kafka_msgset_reader_msg_v2:674): expected 18446744073709551597 bytes > 403 remaining bytes (truncated response from broker (ok))
%7|1627884416.243|CONSUME|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0]: Increasing max fetch bytes to 33554432
%7|1627884416.243|CONSUME|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Enqueue 0 message(s) (0 ops) on TOPIC [0] fetch queue (qlen 0, v2, last_offset -1)
%7|1627884416.243|BACKOFF|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Fetch backoff for 500ms: Local: Read underflow
%7|1627884416.245|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] in state active at offset 275431358 (0/100000 msgs, 0/1048576 kb queued, opv 2) is not fetchable: fetch backed off
%7|1627884416.245|FETCHADD|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Removed TOPIC [0] from fetch list (0 entries, opv 2)
%7|1627884416.245|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 498ms
%7|1627884416.310|RECV|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Received FetchResponse (v4, 16777280 bytes, CorrId 9, rtt 85.72ms)
%7|1627884416.310|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] MessageSet size 16777216, error "Success", MaxOffset 281557267, Ver 2/2
%7|1627884416.310|MSG|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Skip offset 275425892 < fetch_offset 275425955
%7|1627884416.310|MSG|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Skip offset 275425897 < fetch_offset 275425955
%7|1627884416.310|PROTOUFLOW|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Protocol read buffer underflow at 173/574 (rd_kafka_msgset_reader_msg_v2:674): expected 18446744073709551597 bytes > 401 remaining bytes (truncated response from broker (ok))
%7|1627884416.310|CONSUME|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1]: Increasing max fetch bytes to 33554432
%7|1627884416.310|CONSUME|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Enqueue 0 message(s) (0 ops) on TOPIC [1] fetch queue (qlen 0, v2, last_offset -1)
%7|1627884416.310|BACKOFF|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Fetch backoff for 500ms: Local: Read underflow
%7|1627884416.312|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] in state active at offset 275425955 (0/100000 msgs, 0/1048576 kb queued, opv 2) is not fetchable: fetch backed off
%7|1627884416.312|FETCHADD|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Removed TOPIC [1] from fetch list (0 entries, opv 2)
%7|1627884416.312|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 498ms
%7|1627884416.744|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] in state active at offset 275431358 (0/100000 msgs, 0/1048576 kb queued, opv 2) is fetchable:
%7|1627884416.744|FETCHADD|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Added TOPIC [0] to fetch list (1 entries, opv 2)
%7|1627884416.744|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch topic TOPIC [0] at offset 275431358 (v2)
%7|1627884416.744|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch 1/1/1 toppar(s)
%7|1627884416.744|SEND|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Sent FetchRequest (v4, 84 bytes @ 0, CorrId 8)
%7|1627884416.809|RECV|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Received FetchResponse (v4, 33554496 bytes, CorrId 8, rtt 65.46ms)
%7|1627884416.809|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] MessageSet size 33554432, error "Success", MaxOffset 281565634, Ver 2/2
%7|1627884416.809|MSG|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Skip offset 275431295 < fetch_offset 275431358
%7|1627884416.809|MSG|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Skip offset 275431300 < fetch_offset 275431358
%7|1627884416.809|PROTOUFLOW|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Protocol read buffer underflow at 173/576 (rd_kafka_msgset_reader_msg_v2:674): expected 18446744073709551597 bytes > 403 remaining bytes (truncated response from broker (ok))
%7|1627884416.809|CONSUME|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0]: Increasing max fetch bytes to 67108864
%7|1627884416.809|CONSUME|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Enqueue 0 message(s) (0 ops) on TOPIC [0] fetch queue (qlen 0, v2, last_offset -1)
%7|1627884416.809|BACKOFF|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Fetch backoff for 500ms: Local: Read underflow
%7|1627884416.810|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] in state active at offset 275425955 (0/100000 msgs, 0/1048576 kb queued, opv 2) is fetchable:
%7|1627884416.810|FETCHADD|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Added TOPIC [1] to fetch list (1 entries, opv 2)
%7|1627884416.810|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch topic TOPIC [1] at offset 275425955 (v2)
%7|1627884416.810|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch 1/1/1 toppar(s)
%7|1627884416.810|SEND|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Sent FetchRequest (v4, 84 bytes @ 0, CorrId 10)
%7|1627884416.814|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] in state active at offset 275431358 (0/100000 msgs, 0/1048576 kb queued, opv 2) is not fetchable: fetch backed off
%7|1627884416.814|FETCHADD|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Removed TOPIC [0] from fetch list (0 entries, opv 2)
%7|1627884416.814|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 495ms
%7|1627884416.900|RECV|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Received FetchResponse (v4, 33554496 bytes, CorrId 10, rtt 89.52ms)
%7|1627884416.900|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] MessageSet size 33554432, error "Success", MaxOffset 281557289, Ver 2/2
%7|1627884416.900|MSG|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Skip offset 275425892 < fetch_offset 275425955
%7|1627884416.900|MSG|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Skip offset 275425897 < fetch_offset 275425955
%7|1627884416.900|PROTOUFLOW|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Protocol read buffer underflow at 173/574 (rd_kafka_msgset_reader_msg_v2:674): expected 18446744073709551597 bytes > 401 remaining bytes (truncated response from broker (ok))
%7|1627884416.900|CONSUME|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1]: Increasing max fetch bytes to 67108864
%7|1627884416.900|CONSUME|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Enqueue 0 message(s) (0 ops) on TOPIC [1] fetch queue (qlen 0, v2, last_offset -1)
%7|1627884416.900|BACKOFF|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Fetch backoff for 500ms: Local: Read underflow
%7|1627884416.903|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] in state active at offset 275425955 (0/100000 msgs, 0/1048576 kb queued, opv 2) is not fetchable: fetch backed off
%7|1627884416.904|FETCHADD|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Removed TOPIC [1] from fetch list (0 entries, opv 2)
%7|1627884416.904|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 496ms
%7|1627884417.310|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] in state active at offset 275431358 (0/100000 msgs, 0/1048576 kb queued, opv 2) is fetchable:
%7|1627884417.310|FETCHADD|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Added TOPIC [0] to fetch list (1 entries, opv 2)
%7|1627884417.310|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch topic TOPIC [0] at offset 275431358 (v2)
%7|1627884417.310|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch 1/1/1 toppar(s)
%7|1627884417.310|SEND|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Sent FetchRequest (v4, 84 bytes @ 0, CorrId 9)
%7|1627884417.396|RECV|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Received FetchResponse (v4, 52428864 bytes, CorrId 9, rtt 86.50ms)
%7|1627884417.396|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] MessageSet size 52428800, error "Success", MaxOffset 281565651, Ver 2/2
%7|1627884417.396|MSG|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Skip offset 275431295 < fetch_offset 275431358
%7|1627884417.396|MSG|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Skip offset 275431300 < fetch_offset 275431358
%7|1627884417.396|PROTOUFLOW|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Protocol read buffer underflow at 173/576 (rd_kafka_msgset_reader_msg_v2:674): expected 18446744073709551597 bytes > 403 remaining bytes (truncated response from broker (ok))
%7|1627884417.396|CONSUME|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0]: Increasing max fetch bytes to 134217728
%7|1627884417.396|CONSUME|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Enqueue 0 message(s) (0 ops) on TOPIC [0] fetch queue (qlen 0, v2, last_offset -1)
%7|1627884417.396|BACKOFF|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: TOPIC [0]: Fetch backoff for 500ms: Local: Read underflow
%7|1627884417.400|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] in state active at offset 275425955 (0/100000 msgs, 0/1048576 kb queued, opv 2) is fetchable:
%7|1627884417.400|FETCHADD|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Added TOPIC [1] to fetch list (1 entries, opv 2)
%7|1627884417.400|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch topic TOPIC [1] at offset 275425955 (v2)
%7|1627884417.400|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch 1/1/1 toppar(s)
%7|1627884417.401|SEND|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Sent FetchRequest (v4, 84 bytes @ 0, CorrId 11)
%7|1627884417.402|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Topic TOPIC [0] in state active at offset 275431358 (0/100000 msgs, 0/1048576 kb queued, opv 2) is not fetchable: fetch backed off
%7|1627884417.402|FETCHADD|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Removed TOPIC [0] from fetch list (0 entries, opv 2)
%7|1627884417.402|FETCH|rdkafka#consumer-1| [thrd:broker01:6667/1]: broker01:6667/1: Fetch backoff for 494ms
%7|1627884417.524|RECV|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Received FetchResponse (v4, 52428864 bytes, CorrId 11, rtt 123.82ms)
%7|1627884417.524|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] MessageSet size 52428800, error "Success", MaxOffset 281557305, Ver 2/2
%7|1627884417.524|MSG|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Skip offset 275425892 < fetch_offset 275425955
%7|1627884417.524|MSG|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Skip offset 275425897 < fetch_offset 275425955
%7|1627884417.524|PROTOUFLOW|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Protocol read buffer underflow at 173/574 (rd_kafka_msgset_reader_msg_v2:674): expected 18446744073709551597 bytes > 401 remaining bytes (truncated response from broker (ok))
%7|1627884417.524|CONSUME|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1]: Increasing max fetch bytes to 134217728
%7|1627884417.524|CONSUME|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Enqueue 0 message(s) (0 ops) on TOPIC [1] fetch queue (qlen 0, v2, last_offset -1)
%7|1627884417.524|BACKOFF|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: TOPIC [1]: Fetch backoff for 500ms: Local: Read underflow
%7|1627884417.530|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Topic TOPIC [1] in state active at offset 275425955 (0/100000 msgs, 0/1048576 kb queued, opv 2) is not fetchable: fetch backed off
%7|1627884417.530|FETCHADD|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Removed TOPIC [1] from fetch list (0 entries, opv 2)
%7|1627884417.530|FETCH|rdkafka#consumer-1| [thrd:broker02:6667/bootstrap]: broker02:6667/2: Fetch backoff for 494ms
Jul 30 '21 08:07 apellegr06
And the same topic is readable with kafka-console-consumer tool
And it's working with the docker version :
docker run -it edenhill/kafkacat:1.6.0 -C -b brokerhost:6667 -t TOPIC
Jul 30 '21 08:07 apellegr06
kcat kcat copied to clipboard

ERROR: Local: Broker transport failure: sasl_plaintext://brokerhost:6667/bootstrap: Receive failed: Disconnected

kcat
kcat copied to clipboard
