.Net client does not receive messages

Description
Messages published both with the Apache binaries or with Confluent Kafka DotNet NuGet are not read with the .Net consumer.
When using the Apache consumer, I am able to read messages from these topics.
I have tried switching to other Kafka clusters, one is Apache Kafka cluster on Windows with 3 brokers on another machine, one is a Confluent Kafka cluster with one broker on my local Docker.
In an attempt to figure out what is going on I used the following code, based on the default implementation, that should result in all known events being logged:
using static System.Console;

//Custom serializer in order to see what happens in the Deserializer
public class MyDeserializer : IDeserializer<string> {
	IEnumerable<KeyValuePair<string, object>> IDeserializer<string>.Configure(IEnumerable<KeyValuePair<string, object>> config, bool isKey) {
		WriteLine($"Configuring deserializer for {(isKey?"key":"value")}");
		return config;
	}

	string IDeserializer<string>.Deserialize(string topic, byte[] data) {
		WriteLine($"Deserializing content from topic '{topic}'");
		WriteLine($"Message contains {data?.Length} bytes");
		var result = Encoding.UTF8.GetString(data);
		return result;
	}

	void IDisposable.Dispose() {
		//throw new NotImplementedException();
	}
}

private static void Consume(CancellationToken token, IEnumerable<string> topics, string broker) {
	var conf = new Dictionary<string, object>
				{
					{ "log_level",               7                              },
					{ "group.id",                "Tools-Kafka-Consumer-Console" },
					{ "bootstrap.servers",       broker                         },
					{ "auto.commit.interval.ms", 5000                           },
					{ "auto.offset.reset",       "earliest"                     },
					{ "socket.blocking.max.ms",  1                              } //suggested by GitHub ReadMe
				};

	using (var consumer = new Consumer<string, string>(conf, new MyDeserializer(), new MyDeserializer())) {
		consumer.Subscribe(topics); //comma-separated list of topics, see output

		//provide console output for every possible event

		consumer.OnMessage += (_, msg)
			=> WriteLine($"[{msg.Topic} > {msg.Offset}] {msg.Key} \\ {msg.Value}");

		consumer.OnStatistics += (_, msg)
			=> WriteLine($"Stats '{msg}'");

		consumer.OnError += (_, error)
			=> WriteLine($"Error ({error.Code}): {error.Reason}");

		consumer.OnOffsetsCommitted += (_, offset)
			=> WriteLine($"Offsets committed ({offset.Offsets})");

		consumer.OnPartitionsAssigned += (_, partitions)
			=> WriteLine($"Partitions assigned: {string.Join(Environment.NewLine, partitions.GroupBy(x => x.Topic).Select(x => $"{x.Key} ({string.Join(",", x.Select(y => y.Partition))})"))})");

		consumer.OnPartitionsRevoked += (_, partitions)
			=> WriteLine($"Partitions revoked: {string.Join(Environment.NewLine, partitions.GroupBy(x => x.Topic).Select(x => $"{x.Key} ({string.Join(",", x.Select(y => y.Partition))})"))})");

		consumer.OnConsumeError += (_, error)
			=> WriteLine($"Consume error ({error.Error.Code}): {error.Error.Reason}");

		consumer.OnLog += (_, log)
			=> WriteLine($"[{log.Level}] {log.Name} > {log.Message}");

		while (!token.IsCancellationRequested)
			consumer.Poll(TimeSpan.FromMilliseconds(100));

		WriteLine($"Stopped");
	}
}

The consumer does only report on partitions being assigned:
Configuring deserializer for key
Configuring deserializer for value
Partitions assigned: test (0)
MYLARGETOPIC.ONE (0,1,2,3,4,5,6,7,8,9,10,11,12,13,14,15,16,17,18,19,20,21,22,23,24,25,26,27,28,29,30,31,32,33,34,35,36,37,38,39,40,41,42,43,44,45,46,47,48,49)
MYLARGETOPIC.TWO (0,1,2,3,4,5,6,7,8,9,10,11,12,13,14,15,16,17,18,19,20,21,22,23,24,25,26,27,28,29,30,31,32,33,34,35,36,37,38,39,40,41,42,43,44,45,46,47,48,49)
HelloWorld (0))

That's it, no other events fire (of course I'm writing messages to the mentioned topics).
I'm very new to Kafka, so maybe there is some obvious configuration or debugging information I'm overlooking.
As a side note: the ReadMe states the first Deserializer (for keys) is passed as a null-reference, but the current version does not allow that.
How to reproduce
see code example
Checklist
Please provide the following information:

[x] Confluent.Kafka nuget version: 0.11.5 and 1.0.0.-experimental-9
[x] Apache Kafka version: <IP_ADDRESS>
[ ] Client configuration:
[x] Operating system:Windows 10
[ ] Provide logs (with "debug" : "..." as necessary in configuration)
[ ] Provide broker log excerpts
[ ] Critical issue

I don't immediately see the problem. try setting the debug config property to all for more insight (adjusting the log_level parameter isn't very useful in practice)

@mhowlett thanks for your quick response and suggestion.
This result in quite some output, in which the only error I see mentioned is:
[7] rdkafka#consumer-1 > [thrd:main]: OffsetCommit internal error: Local: No offset stored
Around line 697 you see the events being fired. (Partition assignment).
Around line 780 you see me cancelling the token, which is picked up at line 784.
After this cancellation you see the shutdown procedure being initiated in the dispose method.
As this take too long, I killed the process manually.
Configuring desializer for key
Configuring desializer for value
7|2018-08-21 11:38:11.565|rdkafka#consumer-1|MEMBERID| [thrd:app]: Group "Tools-Kafka-Consumer-Console": updating member id "(not-set)" -> ""
7|2018-08-21 11:38:11.584|rdkafka#consumer-1|BROKER| [thrd:app]: BROKER3:9092/bootstrap: Added new broker with NodeId -1
7|2018-08-21 11:38:11.585|rdkafka#consumer-1|BROKER| [thrd:app]: BROKER3:9093/bootstrap: Added new broker with NodeId -1
7|2018-08-21 11:38:11.585|rdkafka#consumer-1|BRKMAIN| [thrd::0/internal]: :0/internal: Enter main broker thread
7|2018-08-21 11:38:11.585|rdkafka#consumer-1|BRKMAIN| [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Enter main broker thread
7|2018-08-21 11:38:11.585|rdkafka#consumer-1|CONNECT| [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: broker in state INIT connecting
7|2018-08-21 11:38:11.585|rdkafka#consumer-1|BROKER| [thrd:app]: BROKER3:9094/bootstrap: Added new broker with NodeId -1
7|2018-08-21 11:38:11.585|rdkafka#consumer-1|STATE| [thrd::0/internal]: :0/internal: Broker changed state INIT -> UP
7|2018-08-21 11:38:11.585|rdkafka#consumer-1|BRKREASSIGN| [thrd:main]: Group "Tools-Kafka-Consumer-Console" management reassigned from broker (none) to :0/internal
7|2018-08-21 11:38:11.586|rdkafka#consumer-1|CGRPSTATE| [thrd:main]: Group "Tools-Kafka-Consumer-Console" changed state init -> wait-broker (v1, join-state init)
7|2018-08-21 11:38:11.585|rdkafka#consumer-1|BRKMAIN| [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Enter main broker thread
7|2018-08-21 11:38:11.586|rdkafka#consumer-1|CONNECT| [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: broker in state INIT connecting
7|2018-08-21 11:38:11.585|rdkafka#consumer-1|BRKMAIN| [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Enter main broker thread
7|2018-08-21 11:38:11.587|rdkafka#consumer-1|CONNECT| [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: broker in state INIT connecting
7|2018-08-21 11:38:11.585|rdkafka#consumer-1|INIT| [thrd:app]: librdkafka v0.11.5 (0xb05ff) rdkafka#consumer-1 initialized (debug 0xffff)
7|2018-08-21 11:38:11.585|rdkafka#consumer-1|BROADCAST| [thrd::0/internal]: Broadcasting state change
7|2018-08-21 11:38:11.586|rdkafka#consumer-1|BROADCAST| [thrd:main]: Broadcasting state change
7|2018-08-21 11:38:11.588|rdkafka#consumer-1|BRKASSIGN| [thrd:main]: Group "Tools-Kafka-Consumer-Console" management assigned to broker :0/internal
7|2018-08-21 11:38:11.589|rdkafka#consumer-1|CGRPOP| [thrd:main]: Group "Tools-Kafka-Consumer-Console" received op SUBSCRIBE (v0) in state wait-broker (join state init, v1 vs 0)
7|2018-08-21 11:38:11.589|rdkafka#consumer-1|SUBSCRIBE| [thrd:main]: Group "Tools-Kafka-Consumer-Console": subscribe to new subscription of 2 topics (join state init)
7|2018-08-21 11:38:11.589|rdkafka#consumer-1|UNSUBSCRIBE| [thrd:main]: Group "Tools-Kafka-Consumer-Console": unsubscribe from current unset subscription of 0 topics (leave group=no, join state init, v1)
7|2018-08-21 11:38:11.590|rdkafka#consumer-1|GRPLEADER| [thrd:main]: Group "Tools-Kafka-Consumer-Console": resetting group leader info: unsubscribe
7|2018-08-21 11:38:11.590|rdkafka#consumer-1|CGRPJOINSTATE| [thrd:main]: Group "Tools-Kafka-Consumer-Console" changed join state init -> wait-unassign (v1, state wait-broker)
7|2018-08-21 11:38:11.590|rdkafka#consumer-1|UNASSIGN| [thrd:main]: Group "Tools-Kafka-Consumer-Console": unassign done in state wait-broker (join state wait-unassign): without new assignment: unassign (no previous assignment)
7|2018-08-21 11:38:11.590|rdkafka#consumer-1|CGRPJOINSTATE| [thrd:main]: Group "Tools-Kafka-Consumer-Console" changed join state wait-unassign -> init (v1, state wait-broker)
7|2018-08-21 11:38:11.590|rdkafka#consumer-1|CGRPQUERY| [thrd:main]: Group "Tools-Kafka-Consumer-Console": no broker available for coordinator query: intervaled in state wait-broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Connecting to ipv4#<IP_ADDRESS>:9093 (plaintext) with socket 1440
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Connecting to ipv4#<IP_ADDRESS>:9094 (plaintext) with socket 1448
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Broker changed state INIT -> CONNECT
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Broker changed state INIT -> CONNECT
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Connected to ipv4#<IP_ADDRESS>:9094
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Connected (#1)
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Connected to ipv4#<IP_ADDRESS>:9093
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Connecting to ipv4#<IP_ADDRESS>:9092 (plaintext) with socket 1460
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Connected (#1)
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Broker changed state INIT -> CONNECT
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Connected to ipv4#<IP_ADDRESS>:9092
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Connected (#1)
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Sent ApiVersionRequest (v0, 25 bytes @ 0, CorrId 1)
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Received ApiVersionResponse (v0, 264 bytes, CorrId 1, rtt 3.33ms)
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Broker API support:
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey Produce (0) Versions 0..5
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey Fetch (1) Versions 0..7
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey Offset (2) Versions 0..2
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey Metadata (3) Versions 0..5
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey LeaderAndIsr (4) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey StopReplica (5) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey Unknown-6? (6) Versions 0..4
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey Unknown-7? (7) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey OffsetCommit (8) Versions 0..3
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey OffsetFetch (9) Versions 0..3
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey GroupCoordinator (10) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey JoinGroup (11) Versions 0..2
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey Heartbeat (12) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Sent ApiVersionRequest (v0, 25 bytes @ 0, CorrId 1)
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Received ApiVersionResponse (v0, 264 bytes, CorrId 1, rtt 6.26ms)
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Broker API support:
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey Produce (0) Versions 0..5
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey Fetch (1) Versions 0..7
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey Offset (2) Versions 0..2
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey Metadata (3) Versions 0..5
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Sent ApiVersionRequest (v0, 25 bytes @ 0, CorrId 1)
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Received ApiVersionResponse (v0, 264 bytes, CorrId 1, rtt 6.42ms)
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey LeaveGroup (13) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey SyncGroup (14) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey LeaderAndIsr (4) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Broker API support:
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey Produce (0) Versions 0..5
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey Fetch (1) Versions 0..7
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey DescribeGroups (15) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey StopReplica (5) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey ListGroups (16) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey SaslHandshake (17) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey ApiVersion (18) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey Offset (2) Versions 0..2
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey Unknown-6? (6) Versions 0..4
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey CreateTopics (19) Versions 0..2
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey Unknown-7? (7) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey Metadata (3) Versions 0..5
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey LeaderAndIsr (4) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey StopReplica (5) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey DeleteTopics (20) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey OffsetCommit (8) Versions 0..3
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey OffsetFetch (9) Versions 0..3
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey Unknown-6? (6) Versions 0..4
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey DeleteRecords (21) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey GroupCoordinator (10) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey Unknown-7? (7) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey JoinGroup (11) Versions 0..2
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey InitProducerId (22) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey OffsetCommit (8) Versions 0..3
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey OffsetFetch (9) Versions 0..3
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey GroupCoordinator (10) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey Heartbeat (12) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey OffsetForLeaderEpoch (23) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey JoinGroup (11) Versions 0..2
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey Heartbeat (12) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey LeaveGroup (13) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey LeaveGroup (13) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey AddPartitionsToTxn (24) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey SyncGroup (14) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey DescribeGroups (15) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey SyncGroup (14) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey AddOffsetsToTxn (25) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey ListGroups (16) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey DescribeGroups (15) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey EndTxn (26) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey SaslHandshake (17) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey ApiVersion (18) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey ListGroups (16) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey WriteTxnMarkers (27) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey CreateTopics (19) Versions 0..2
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey SaslHandshake (17) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey ApiVersion (18) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey CreateTopics (19) Versions 0..2
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey TxnOffsetCommit (28) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey DeleteTopics (20) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey DescribeAcls (29) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey CreateAcls (30) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey DeleteTopics (20) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey DeleteRecords (21) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey InitProducerId (22) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey DeleteRecords (21) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey InitProducerId (22) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey OffsetForLeaderEpoch (23) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey AddPartitionsToTxn (24) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey AddOffsetsToTxn (25) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey DeleteAcls (31) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey OffsetForLeaderEpoch (23) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey EndTxn (26) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey WriteTxnMarkers (27) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey TxnOffsetCommit (28) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey DescribeAcls (29) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey CreateAcls (30) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey DeleteAcls (31) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey DescribeConfigs (32) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey DescribeConfigs (32) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey AddPartitionsToTxn (24) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey AlterConfigs (33) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey AlterReplicaLogDirs (34) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey AlterConfigs (33) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey AlterReplicaLogDirs (34) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey AddOffsetsToTxn (25) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey EndTxn (26) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey DescribeLogDirs (35) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey SaslAuthenticate (36) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey CreatePartitions (37) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey CreateDelegationToken (38) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey RenewDelegationToken (39) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey WriteTxnMarkers (27) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey DescribeLogDirs (35) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey SaslAuthenticate (36) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey CreatePartitions (37) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey CreateDelegationToken (38) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey RenewDelegationToken (39) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey ExpireDelegationToken (40) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey ExpireDelegationToken (40) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey DescribeDelegationToken (41) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey TxnOffsetCommit (28) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey DescribeDelegationToken (41) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:   ApiKey DeleteGroups (42) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature MsgVer1: Produce (2..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature MsgVer1: Fetch (2..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Enabling feature MsgVer1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature MsgVer2: Produce (3..3) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature MsgVer2: Fetch (4..4) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Enabling feature MsgVer2
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:   ApiKey DeleteGroups (42) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature MsgVer1: Produce (2..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey DescribeAcls (29) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey CreateAcls (30) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature ApiVersion: ApiVersion (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature MsgVer1: Fetch (2..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Enabling feature MsgVer1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature MsgVer2: Produce (3..3) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature MsgVer2: Fetch (4..4) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Enabling feature MsgVer2
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature ApiVersion: ApiVersion (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Enabling feature ApiVersion
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey DeleteAcls (31) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey DescribeConfigs (32) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey AlterConfigs (33) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Enabling feature ApiVersion
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Enabling feature BrokerGroupCoordinator
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey AlterReplicaLogDirs (34) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Enabling feature BrokerGroupCoordinator
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey DescribeLogDirs (35) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey SaslAuthenticate (36) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey CreatePartitions (37) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey CreateDelegationToken (38) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey RenewDelegationToken (39) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey ExpireDelegationToken (40) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Enabling feature BrokerBalancedConsumer
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey DescribeDelegationToken (41) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:   ApiKey DeleteGroups (42) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Enabling feature BrokerBalancedConsumer
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature ThrottleTime: Produce (1..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature ThrottleTime: Fetch (1..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Enabling feature ThrottleTime
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature Sasl: JoinGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature ThrottleTime: Produce (1..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature MsgVer1: Produce (2..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature MsgVer1: Fetch (2..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Enabling feature MsgVer1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Enabling feature Sasl
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature ThrottleTime: Fetch (1..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Enabling feature ThrottleTime
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature Sasl: JoinGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Enabling feature Sasl
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Enabling feature SaslHandshake
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature LZ4: GroupCoordinator (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Enabling feature LZ4
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature MsgVer2: Produce (3..3) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature OffsetTime: Offset (1..1) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Enabling feature OffsetTime
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature : CreateTopics (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Enabling feature SaslHandshake
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature LZ4: GroupCoordinator (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Enabling feature LZ4
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature OffsetTime: Offset (1..1) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature MsgVer2: Fetch (4..4) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Enabling feature MsgVer2
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature ApiVersion: ApiVersion (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Enabling feature ApiVersion
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Enabling feature BrokerGroupCoordinator
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap:  Feature : DeleteTopics (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Enabling feature OffsetTime
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Enabling feature
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature : CreateTopics (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Request metadata for brokers only: connected
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Sent MetadataRequest (v2, 25 bytes @ 0, CorrId 2)
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Received MetadataResponse (v2, 123 bytes, CorrId 2, rtt 1.01ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9092/bootstrap: ===== Received metadata: connected =====
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap:  Feature : DeleteTopics (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Enabling feature
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9092/bootstrap: ClusterId: yHBgfMNMRyyaovwxXROTMQ, ControllerId: 1
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9092/bootstrap: 3 brokers, 0 topics
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9092/bootstrap:   Broker #0/3: BROKER3.LOCAL:9094 NodeId 2
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Broker changed state APIVERSION_QUERY -> UP
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Enabling feature BrokerBalancedConsumer
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature ThrottleTime: Produce (1..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature ThrottleTime: Fetch (1..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Enabling feature ThrottleTime
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature Sasl: JoinGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Enabling feature Sasl
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Enabling feature SaslHandshake
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature LZ4: GroupCoordinator (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Enabling feature LZ4
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature OffsetTime: Offset (1..1) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Enabling feature OffsetTime
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature : CreateTopics (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap:  Feature : DeleteTopics (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Enabling feature
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Broker changed state APIVERSION_QUERY -> UP
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9094/2: Added new broker with NodeId 2
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9092/bootstrap:   Broker #1/3: BROKER3.LOCAL:9093 NodeId 1
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9093/1: Added new broker with NodeId 1
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Request metadata for brokers only: connected
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9092/bootstrap:   Broker #2/3: BROKER3.LOCAL:9092 NodeId 0
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Request metadata for brokers only: connected
[7] rdkafka#consumer-1 > [thrd:BROKER3:9094/bootstrap]: BROKER3:9094/bootstrap: Skipping metadata request: connected: full request already in-transit
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Skipping metadata request: connected: full request already in-transit
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Added new broker with NodeId 0
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9092/bootstrap: ClusterId update "" -> "yHBgfMNMRyyaovwxXROTMQ"
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9092/bootstrap: ControllerId update -1 -> 1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Enter main broker thread
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Enter main broker thread
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Enter main broker thread
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: broker in state INIT connecting
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: broker in state INIT connecting
[7] rdkafka#consumer-1 > [thrd:main]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": no topics in metadata matched subscription
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console" management reassigned from broker :0/internal to BROKER3:9093/bootstrap
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console" management unassigned from broker handle :0/internal
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Connecting to ipv4#<IP_ADDRESS>:9092 (plaintext) with socket 1472
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Connecting to ipv4#<IP_ADDRESS>:9093 (plaintext) with socket 1468
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: broker in state INIT connecting
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Broker changed state INIT -> CONNECT
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console" management assigned to broker BROKER3:9093/bootstrap
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Connected to ipv4#<IP_ADDRESS>:9092
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Connected (#1)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Updated enabled protocol features +ApiVersion to ApiVersion
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Broker changed state INIT -> CONNECT
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Connecting to ipv4#<IP_ADDRESS>:9094 (plaintext) with socket 1608
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Broker changed state INIT -> CONNECT
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Connected to ipv4#<IP_ADDRESS>:9094
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Connected (#1)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Broker changed state CONNECT -> APIVERSION_QUERY
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Updated enabled protocol features +ApiVersion to ApiVersion
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Connected to ipv4#<IP_ADDRESS>:9093
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Connected (#1)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Broker changed state CONNECT -> APIVERSION_QUERY
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Updated enabled protocol features +ApiVersion to ApiVersion
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Broker changed state CONNECT -> APIVERSION_QUERY
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9093/bootstrap: Group "Tools-Kafka-Consumer-Console": querying for coordinator: intervaled in state wait-broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Sent ApiVersionRequest (v0, 25 bytes @ 0, CorrId 1)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent ApiVersionRequest (v0, 25 bytes @ 0, CorrId 1)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Sent ApiVersionRequest (v0, 25 bytes @ 0, CorrId 1)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Received ApiVersionResponse (v0, 264 bytes, CorrId 1, rtt 6.85ms)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Broker API support:
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Sent GroupCoordinatorRequest (v0, 51 bytes @ 0, CorrId 2)
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Received GroupCoordinatorResponse (v0, 29 bytes, CorrId 2, rtt 7.11ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9093/bootstrap: Group "Tools-Kafka-Consumer-Console" coordinator is BROKER3.LOCAL:9092 id 0
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console" changing coordinator -1 -> 0
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console" management reassigned from broker BROKER3:9093/bootstrap to BROKER3.LOCAL:9092/0
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console" management unassigned from broker handle BROKER3:9093/bootstrap
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console" management assigned to broker BROKER3.LOCAL:9092/0
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console" changed state wait-broker -> wait-broker-transport (v1, join-state init)
[7] rdkafka#consumer-1 > [thrd:main]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9093/bootstrap: Group "Tools-Kafka-Consumer-Console": querying for coordinator: intervaled in state wait-broker-transport
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received ApiVersionResponse (v0, 264 bytes, CorrId 1, rtt 7.76ms)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Received ApiVersionResponse (v0, 264 bytes, CorrId 1, rtt 4.84ms)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey Produce (0) Versions 0..5
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Sent GroupCoordinatorRequest (v0, 51 bytes @ 0, CorrId 3)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Broker API support:
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey Produce (0) Versions 0..5
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey Fetch (1) Versions 0..7
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey Offset (2) Versions 0..2
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey Metadata (3) Versions 0..5
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey LeaderAndIsr (4) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey StopReplica (5) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey Unknown-6? (6) Versions 0..4
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey Unknown-7? (7) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Broker API support:
[7] rdkafka#consumer-1 > [thrd:BROKER3:9093/bootstrap]: BROKER3:9093/bootstrap: Received GroupCoordinatorResponse (v0, 29 bytes, CorrId 3, rtt 9.14ms)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey Fetch (1) Versions 0..7
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey OffsetCommit (8) Versions 0..3
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey Produce (0) Versions 0..5
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9093/bootstrap: Group "Tools-Kafka-Consumer-Console" coordinator is BROKER3.LOCAL:9092 id 0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey Offset (2) Versions 0..2
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey OffsetFetch (9) Versions 0..3
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey GroupCoordinator (10) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey Fetch (1) Versions 0..7
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey Offset (2) Versions 0..2
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey Metadata (3) Versions 0..5
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey Metadata (3) Versions 0..5
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey LeaderAndIsr (4) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey JoinGroup (11) Versions 0..2
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey StopReplica (5) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey LeaderAndIsr (4) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey Heartbeat (12) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey LeaveGroup (13) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey SyncGroup (14) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey DescribeGroups (15) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey ListGroups (16) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey SaslHandshake (17) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey ApiVersion (18) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey CreateTopics (19) Versions 0..2
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey Unknown-6? (6) Versions 0..4
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey StopReplica (5) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey Unknown-7? (7) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey OffsetCommit (8) Versions 0..3
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey DeleteTopics (20) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey DeleteRecords (21) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey InitProducerId (22) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey OffsetForLeaderEpoch (23) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey AddPartitionsToTxn (24) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey AddOffsetsToTxn (25) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey EndTxn (26) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey Unknown-6? (6) Versions 0..4
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey OffsetFetch (9) Versions 0..3
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey GroupCoordinator (10) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey WriteTxnMarkers (27) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey Unknown-7? (7) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey OffsetCommit (8) Versions 0..3
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey OffsetFetch (9) Versions 0..3
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey GroupCoordinator (10) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey JoinGroup (11) Versions 0..2
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey JoinGroup (11) Versions 0..2
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey Heartbeat (12) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey LeaveGroup (13) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey TxnOffsetCommit (28) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey DescribeAcls (29) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey Heartbeat (12) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey LeaveGroup (13) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey SyncGroup (14) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey CreateAcls (30) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey SyncGroup (14) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey DescribeGroups (15) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey DescribeGroups (15) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey DeleteAcls (31) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey ListGroups (16) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey ListGroups (16) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey SaslHandshake (17) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey ApiVersion (18) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey CreateTopics (19) Versions 0..2
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey DescribeConfigs (32) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey DeleteTopics (20) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey DeleteRecords (21) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey SaslHandshake (17) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey AlterConfigs (33) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey AlterReplicaLogDirs (34) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey DescribeLogDirs (35) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey SaslAuthenticate (36) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey CreatePartitions (37) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey CreateDelegationToken (38) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey RenewDelegationToken (39) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey InitProducerId (22) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey OffsetForLeaderEpoch (23) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey ApiVersion (18) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey CreateTopics (19) Versions 0..2
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey DeleteTopics (20) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey AddPartitionsToTxn (24) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey ExpireDelegationToken (40) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey DeleteRecords (21) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey InitProducerId (22) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey OffsetForLeaderEpoch (23) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey AddPartitionsToTxn (24) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey AddOffsetsToTxn (25) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey EndTxn (26) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey WriteTxnMarkers (27) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey AddOffsetsToTxn (25) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey EndTxn (26) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey DescribeDelegationToken (41) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:   ApiKey DeleteGroups (42) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature MsgVer1: Produce (2..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature MsgVer1: Fetch (2..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey TxnOffsetCommit (28) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey WriteTxnMarkers (27) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey TxnOffsetCommit (28) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Enabling feature MsgVer1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature MsgVer2: Produce (3..3) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature MsgVer2: Fetch (4..4) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Enabling feature MsgVer2
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey DescribeAcls (29) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey DescribeAcls (29) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey CreateAcls (30) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey CreateAcls (30) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature ApiVersion: ApiVersion (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Enabling feature ApiVersion
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey DeleteAcls (31) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey DeleteAcls (31) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey DescribeConfigs (32) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey DescribeConfigs (32) Versions 0..1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey AlterConfigs (33) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey AlterReplicaLogDirs (34) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey DescribeLogDirs (35) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Enabling feature BrokerGroupCoordinator
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey AlterConfigs (33) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey AlterReplicaLogDirs (34) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey DescribeLogDirs (35) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey SaslAuthenticate (36) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey SaslAuthenticate (36) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey CreatePartitions (37) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey CreateDelegationToken (38) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey RenewDelegationToken (39) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey CreatePartitions (37) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey CreateDelegationToken (38) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey RenewDelegationToken (39) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey ExpireDelegationToken (40) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey ExpireDelegationToken (40) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey DescribeDelegationToken (41) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Enabling feature BrokerBalancedConsumer
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature ThrottleTime: Produce (1..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature ThrottleTime: Fetch (1..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey DescribeDelegationToken (41) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Enabling feature ThrottleTime
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature Sasl: JoinGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:   ApiKey DeleteGroups (42) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Enabling feature Sasl
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:   ApiKey DeleteGroups (42) Versions 0..0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature MsgVer1: Produce (2..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature MsgVer1: Fetch (2..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Enabling feature SaslHandshake
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature LZ4: GroupCoordinator (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Enabling feature MsgVer1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature MsgVer2: Produce (3..3) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Enabling feature LZ4
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature OffsetTime: Offset (1..1) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Enabling feature OffsetTime
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature MsgVer1: Produce (2..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature MsgVer1: Fetch (2..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature MsgVer2: Fetch (4..4) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature : CreateTopics (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0:  Feature : DeleteTopics (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Enabling feature
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Enabling feature MsgVer1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature MsgVer2: Produce (3..3) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature MsgVer2: Fetch (4..4) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Broker changed state APIVERSION_QUERY -> UP
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Enabling feature MsgVer2
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Enabling feature MsgVer2
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature ApiVersion: ApiVersion (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Enabling feature ApiVersion
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Enabling feature BrokerGroupCoordinator
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature ApiVersion: ApiVersion (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Request metadata for brokers only: connected
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Enabling feature ApiVersion
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Enabling feature BrokerGroupCoordinator
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent MetadataRequest (v2, 25 bytes @ 0, CorrId 2)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received MetadataResponse (v2, 123 bytes, CorrId 2, rtt 3.44ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: ===== Received metadata: connected =====
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: ClusterId: yHBgfMNMRyyaovwxXROTMQ, ControllerId: 1
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: 3 brokers, 0 topics
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0:   Broker #0/3: BROKER3.LOCAL:9094 NodeId 2
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0:   Broker #1/3: BROKER3.LOCAL:9093 NodeId 1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Enabling feature BrokerBalancedConsumer
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature ThrottleTime: Produce (1..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0:   Broker #2/3: BROKER3.LOCAL:9092 NodeId 0
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature ThrottleTime: Fetch (1..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Enabling feature ThrottleTime
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature Sasl: JoinGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": no topics in metadata matched subscription
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Enabling feature Sasl
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Enabling feature BrokerBalancedConsumer
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature ThrottleTime: Produce (1..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console" changed state wait-broker-transport -> up (v1, join-state init)
[7] rdkafka#consumer-1 > [thrd:main]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Enabling feature SaslHandshake
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature ThrottleTime: Fetch (1..2) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Enabling feature ThrottleTime
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": join with 0 (2) subscribed topic(s)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature Sasl: JoinGroup (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature LZ4: GroupCoordinator (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:main]: Hinted cache of 2/2 topic(s) being queried
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Enabling feature Sasl
[7] rdkafka#consumer-1 > [thrd:main]: consumer join: metadata for subscription only available for 0/2 topics (-1ms old)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Enabling feature SaslHandshake
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature LZ4: GroupCoordinator (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Enabling feature LZ4
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature OffsetTime: Offset (1..1) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Enabling feature OffsetTime
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature : CreateTopics (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1:  Feature : DeleteTopics (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Enabling feature
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Enabling feature LZ4
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature OffsetTime: Offset (1..1) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Enabling feature OffsetTime
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature : CreateTopics (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Broker changed state APIVERSION_QUERY -> UP
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2:  Feature : DeleteTopics (0..0) supported by broker
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Request metadata for brokers only: connected
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Sent MetadataRequest (v2, 25 bytes @ 0, CorrId 2)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9093/1]: BROKER3.LOCAL:9093/1: Received MetadataResponse (v2, 123 bytes, CorrId 2, rtt 1.59ms)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Enabling feature
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Broker changed state APIVERSION_QUERY -> UP
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9092/bootstrap: Request metadata for 2 topic(s): consumer join
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Request metadata for brokers only: connected
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9094/2]: BROKER3.LOCAL:9094/2: Skipping metadata request: connected: full request already in-transit
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Sent MetadataRequest (v2, 71 bytes @ 0, CorrId 3)
[7] rdkafka#consumer-1 > [thrd:BROKER3:9092/bootstrap]: BROKER3:9092/bootstrap: Received MetadataResponse (v2, 235 bytes, CorrId 3, rtt 1.77ms)
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": postponing join until up-to-date metadata is available
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9093/1: ===== Received metadata: connected =====
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9093/1: ClusterId: yHBgfMNMRyyaovwxXROTMQ, ControllerId: 1
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9093/1: 3 brokers, 0 topics
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9093/1:   Broker #0/3: BROKER3.LOCAL:9094 NodeId 2
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9093/1:   Broker #1/3: BROKER3.LOCAL:9093 NodeId 1
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9093/1:   Broker #2/3: BROKER3.LOCAL:9092 NodeId 0
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": no topics in metadata matched subscription
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9092/bootstrap: ===== Received metadata (for 2 requested topics): consumer join =====
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9092/bootstrap: ClusterId: yHBgfMNMRyyaovwxXROTMQ, ControllerId: 1
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9092/bootstrap: 3 brokers, 2 topics
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9092/bootstrap:   Broker #0/3: BROKER3.LOCAL:9094 NodeId 2
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9092/bootstrap:   Broker #1/3: BROKER3.LOCAL:9093 NodeId 1
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9092/bootstrap:   Broker #2/3: BROKER3.LOCAL:9092 NodeId 0
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9092/bootstrap:   Topic #0/2: HelloWorld with 1 partitions
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9092/bootstrap:   Topic #1/2: test with 1 partitions
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3:9092/bootstrap: 2/2 requested topic(s) seen in metadata
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": effective subscription list changed from 0 to 2 topic(s):
[7] rdkafka#consumer-1 > [thrd:main]:  Topic HelloWorld with 1 partition(s)
[7] rdkafka#consumer-1 > [thrd:main]:  Topic test with 1 partition(s)
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": subscription updated from metadata change: rejoining group
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": resetting group leader info: Group rejoin
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console" rejoining in join-state init without an assignment
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": join with 2 (2) subscribed topic(s)
[7] rdkafka#consumer-1 > [thrd:main]: consumer join: metadata for subscription is up to date (10ms old)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Joining group "Tools-Kafka-Consumer-Console" with 2 subscribed topic(s)
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console" changed join state init -> wait-join (v1, state up)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent JoinGroupRequest (v0, 210 bytes @ 0, CorrId 3)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received JoinGroupResponse (v0, 215 bytes, CorrId 3, rtt 50.81ms)
[7] rdkafka#consumer-1 > [thrd:main]: JoinGroup response: GenerationId 1, Protocol range, LeaderId rdkafka-c02baa6e-4d60-4516-b89a-316d90ff9a3b (me), my MemberId rdkafka-c02baa6e-4d60-4516-b89a-316d90ff9a3b, 1 members in group: (no error)
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": updating member id "" -> "rdkafka-c02baa6e-4d60-4516-b89a-316d90ff9a3b"
[7] rdkafka#consumer-1 > [thrd:main]: Elected leader for group "Tools-Kafka-Consumer-Console" with 1 member(s)
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": resetting group leader info: JoinGroup response clean-up
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console" changed join state wait-join -> wait-metadata (v1, state up)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Request metadata for 2 topic(s): partition assignor
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent MetadataRequest (v2, 71 bytes @ 0, CorrId 4)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received MetadataResponse (v2, 235 bytes, CorrId 4, rtt 1.06ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: ===== Received metadata (for 2 requested topics): partition assignor =====
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: ClusterId: yHBgfMNMRyyaovwxXROTMQ, ControllerId: 1
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: 3 brokers, 2 topics
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0:   Broker #0/3: BROKER3.LOCAL:9094 NodeId 2
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0:   Broker #1/3: BROKER3.LOCAL:9093 NodeId 1
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0:   Broker #2/3: BROKER3.LOCAL:9092 NodeId 0
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0:   Topic #0/2: HelloWorld with 1 partitions
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0:   Topic #1/2: test with 1 partitions
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: 2/2 requested topic(s) seen in metadata
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console" running range assignment for 1 member(s):
[7] rdkafka#consumer-1 > [thrd:main]:  Member "rdkafka-c02baa6e-4d60-4516-b89a-316d90ff9a3b" (me) with 2 subscription(s):
[7] rdkafka#consumer-1 > [thrd:main]:   HelloWorld [-1]
[7] rdkafka#consumer-1 > [thrd:main]:   test [-1]
[7] rdkafka#consumer-1 > [thrd:main]: range: Topic HelloWorld with 1 partition(s) and 1 subscribing member(s)
[7] rdkafka#consumer-1 > [thrd:main]: range: Member "rdkafka-c02baa6e-4d60-4516-b89a-316d90ff9a3b": assigned topic HelloWorld partitions 0..0
[7] rdkafka#consumer-1 > [thrd:main]: range: Topic test with 1 partition(s) and 1 subscribing member(s)
[7] rdkafka#consumer-1 > [thrd:main]: range: Member "rdkafka-c02baa6e-4d60-4516-b89a-316d90ff9a3b": assigned topic test partitions 0..0
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console" range assignment for 1 member(s) finished in 8.856ms:
[7] rdkafka#consumer-1 > [thrd:main]:  Member "rdkafka-c02baa6e-4d60-4516-b89a-316d90ff9a3b" (me) assigned 2 partition(s):
[7] rdkafka#consumer-1 > [thrd:main]:   HelloWorld [0]
[7] rdkafka#consumer-1 > [thrd:main]:   test [0]
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": "range" assignor run for 1 member(s)
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console" changed join state wait-metadata -> wait-sync (v1, state up)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent SyncGroupRequest (v0, 227 bytes @ 0, CorrId 5)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: Broadcasting state change
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received SyncGroupResponse (v0, 78 bytes, CorrId 5, rtt 59.94ms)
[7] rdkafka#consumer-1 > [thrd:main]: SyncGroup response: Success (72 bytes of MemberState data)
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": delegating assign of 2 partition(s) to application rebalance callback on queue rd_kafka_cgrp_new: new assignment
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console" changed join state wait-sync -> wait-assign-rebalance_cb (v1, state up)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
Partitions assigned: HelloWorld (0)
test (0))
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 6)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 6, rtt 0.86ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:main]: OffsetCommit internal error: Local: No offset stored
[7] rdkafka#consumer-1 > [thrd:main]: OffsetCommit for -1 partition(s): cgrp auto commit timer: returned: Local: No offset stored
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": unassign done in state up (join state wait-assign-rebalance_cb): without new assignment: OffsetCommit done (__NO_OFFSET)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 7)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 7, rtt 1.02ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 8)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 8, rtt 0.91ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 9)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 9, rtt 1.04ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 10)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 10, rtt 1.00ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 11)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 11, rtt 1.09ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:main]: OffsetCommit internal error: Local: No offset stored
[7] rdkafka#consumer-1 > [thrd:main]: OffsetCommit for -1 partition(s): cgrp auto commit timer: returned: Local: No offset stored
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": unassign done in state up (join state wait-assign-rebalance_cb): without new assignment: OffsetCommit done (__NO_OFFSET)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 12)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 12, rtt 0.86ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 13)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 13, rtt 1.02ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 14)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 14, rtt 2.52ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 15)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 15, rtt 1.10ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 16)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 16, rtt 0.83ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:main]: OffsetCommit internal error: Local: No offset stored
[7] rdkafka#consumer-1 > [thrd:main]: OffsetCommit for -1 partition(s): cgrp auto commit timer: returned: Local: No offset stored
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": unassign done in state up (join state wait-assign-rebalance_cb): without new assignment: OffsetCommit done (__NO_OFFSET)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 17)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 17, rtt 1.04ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 18)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 18, rtt 0.84ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 19)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 19, rtt 1.08ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 20)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 20, rtt 0.99ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 21)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 21, rtt 1.09ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:main]: OffsetCommit internal error: Local: No offset stored
[7] rdkafka#consumer-1 > [thrd:main]: OffsetCommit for -1 partition(s): cgrp auto commit timer: returned: Local: No offset stored
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": unassign done in state up (join state wait-assign-rebalance_cb): without new assignment: OffsetCommit done (__NO_OFFSET)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 22)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 22, rtt 28.37ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 23)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 23, rtt 1.83ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 24)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 24, rtt 5.28ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 25)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 25, rtt 1.02ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 26)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 26, rtt 1.99ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
[7] rdkafka#consumer-1 > [thrd:main]: OffsetCommit internal error: Local: No offset stored
[7] rdkafka#consumer-1 > [thrd:main]: OffsetCommit for -1 partition(s): cgrp auto commit timer: returned: Local: No offset stored
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": unassign done in state up (join state wait-assign-rebalance_cb): without new assignment: OffsetCommit done (__NO_OFFSET)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 27)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 27, rtt 0.77ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
Stopping consumer
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 28)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 28, rtt 0.79ms)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Heartbeat for group "Tools-Kafka-Consumer-Console" generation id 1
Stopped
[7] rdkafka#consumer-1 > [thrd:app]: Closing consumer
[7] rdkafka#consumer-1 > [thrd:app]: Waiting for close events
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console" received op TERMINATE (v0) in state up (join state wait-assign-rebalance_cb, v1 vs 0)
[7] rdkafka#consumer-1 > [thrd:main]: Terminating group "Tools-Kafka-Consumer-Console" in state up with 0 partition(s)
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": unsubscribe from current subscription of 2 topics (leave group=yes, join state wait-assign-rebalance_cb, v1)
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": clearing subscribed topics list (2)
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": effective subscription list changed from 2 to 0 topic(s):
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": resetting group leader info: unsubscribe
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent HeartbeatRequest (v0, 101 bytes @ 0, CorrId 29)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received HeartbeatResponse (v0, 2 bytes, CorrId 29, rtt 2.23ms)
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: OffsetCommit internal error: Local: No offset stored
[7] rdkafka#consumer-1 > [thrd:main]: OffsetCommit for -1 partition(s): cgrp auto commit timer: returned: Local: No offset stored
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": unassign done in state up (join state wait-assign-rebalance_cb): without new assignment: OffsetCommit done (__NO_OFFSET)
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": leave (in state up)
[7] rdkafka#consumer-1 > [thrd:main]: BROKER3.LOCAL:9092/0: Leaving group
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Sent LeaveGroupRequest (v0, 97 bytes @ 0, CorrId 30)
[7] rdkafka#consumer-1 > [thrd:BROKER3.LOCAL:9092/0]: BROKER3.LOCAL:9092/0: Received LeaveGroupResponse (v0, 2 bytes, CorrId 30, rtt 6.26ms)
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: OffsetCommit internal error: Local: No offset stored
[7] rdkafka#consumer-1 > [thrd:main]: OffsetCommit for -1 partition(s): cgrp auto commit timer: returned: Local: No offset stored
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": unassign done in state up (join state wait-assign-rebalance_cb): without new assignment: OffsetCommit done (__NO_OFFSET)
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: OffsetCommit internal error: Local: No offset stored
[7] rdkafka#consumer-1 > [thrd:main]: OffsetCommit for -1 partition(s): cgrp auto commit timer: returned: Local: No offset stored
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": unassign done in state up (join state wait-assign-rebalance_cb): without new assignment: OffsetCommit done (__NO_OFFSET)
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating
[7] rdkafka#consumer-1 > [thrd:main]: Group "Tools-Kafka-Consumer-Console": waiting for rebalance_cb, 0 toppar(s), 0 unassignment(s), 0 commit(s) (state up, join-state wait-assign-rebalance_cb) before terminating```

We are just starting to try and use Kafka so I'm not that experienced yet, but:
If you are using partitioning then you won't get any messages until subscriber.Assign(...) is called. This is normally called in response to OnPartitionsAssigned.
However, even with that I always lose the first message because OnMessage is not raised for the message that caused OnPartitionsAssigned to be called.

@Atrejoe - I'm blind! as @Thx1137 points out, you're adding OnPartitionsAssigned/OnPartitionsRevoked handlers but not calling Assign - this is required in 0.11.5. In the 1.0 releases, this is no longer required - the assign will happen automatically if you add a handler and don't call it yourself. In 0.11.5, the assign will only happen automatically if there are not handlers added.
@Thx1137 - that doesn't sound right - there's a lot of testing that covers this, for example: https://github.com/confluentinc/confluent-kafka-dotnet/blob/master/test/Confluent.Kafka.IntegrationTests/Tests/DeserializingConsumer_Poll.cs

@mhowlett and @Thx1137  many thanks, she's running smoothly now!

Hi @mhowlett That example assumes we have the offset from "firstProduced".
The following is using a completely fresh Windows kafka install with 2 servers and 2 partitions.
I have tried a number of variations of:
consumer.Assign(e.Select(p => new TopicPartitionOffset(p, _lastProcessedMessage == null ? Offset.Invalid : _lastProcessedMessage.Offset)));
In our code we:

Initialise the consumer
Initialise the producer
The producer starts pumping out messages once per second
The consumers OnPartitionsAssigned gets called about 8 seconds after the first message was sent.
I execute the above Assign() code
Message sent by the producer AFTER Assign() was called start firing OnMessage.

In our example we lose the first 6 messages because it took that long for OnPartitionsAssigned to be called. Our code is very similar to all the example code I've seen. It seems weird. We are trying to use enable.auto.commit=false but even if I set it to true it still does it.

Hmm. It is all working properly now. The only meaningful change I can see is that now I specify a client.id in the producer and the guy that is doing the consumer is now using lambda expressions for most of the subscriber events but surely that's not why it is no longer missing messages!?

@Thx1137 the sequence of events you describe in 1..6 is intended operation. 8 seconds seems a little long to receive the partition assignment, but could possibly be explained if your consumer uncleanly exiting the group on a previous run.

Thanks mhowlet, I got resolved this issue for consumer. But today I am getting producer issue. getting below error with my code.
public static async Task ProducerService(Iteration reporter)
{
string authLocation = Config.Global.CWD + "\Data\Certificates\" + reporter.Data["KafkaAuthCert"];
string cerLocation = Config.Global.CWD + "\Data\Certificates\" + reporter.Data["KafkaLocCert"];
string keyLoc = Config.Global.CWD + "\Data\Certificates\" + reporter.Data["KafkaKeyCert"];
        var cconfig = new Dictionary<string, object>
            {
                { "bootstrap.servers",reporter.Data["KafkaBrokers"] },
                { "security.protocol", reporter.Data["KafkaProtocal"]},
                { "ssl.ca.location" , authLocation },
                { "api.version.request" ,false },
                { "ssl.certificate.location" , cerLocation },
                { "ssl.key.location" , keyLoc },
                { "debug", "topic,broker,protocol,msg,queue" },
                { "default.topic.config", new Dictionary<string, object> {{ "request.required.acks", -1} } }

            };
        string text = null;
        string topic = "test-topic";
        TopicPartition tp = new TopicPartition(topic, 1);
        TopicPartition tp1 = new TopicPartition(topic, 2);
        TopicPartition tp2 = new TopicPartition(topic, 2);
        try
        {
            using (var producer = new Producer<Null, string>(cconfig, null, new StringSerializer(Encoding.UTF8)))
            {
                while (text != "exit")
                {
                    producer.OnError += (_, e) =>
                    {
                        Console.WriteLine($"Error: {e}");
                    };

                    //producer.ProduceAsync(reporter.Data["Topics"], null, text);
                    //producer.Flush(TimeSpan.FromSeconds(100));
                    var dr = await producer.ProduceAsync(topic, null, text);
                    Console.WriteLine($"Delivered '{dr.Value}' to '{dr.TopicPartitionOffset}'");

                }

                Console.WriteLine(text);
            }
        }
        catch (KafkaException e)
        {
            Console.WriteLine($"Delivery failed: {e.Error.Reason}");
        }
    }

Please let me know if I am missing any thing

does the topic exist in kafka or alternatively is the broker config auto.create.topics.enable set to true? (it is true by default, but it's usually a bad idea so if someone configured the broker for you they may have turned it off)