The Confluent.Kafka C# producer hangs indefinitely when the target partition has no leader. See https://github.com/confluentinc/confluent-kafka-dotnet/issues/1027

ConfluentKafkaProducerHangsOnFlush.cs

using System;
using System.Threading.Tasks;
using Confluent.Kafka;

namespace my_producer
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("Hello World!");

            // Simple producer configuration. Set the timeout to something
            // reasonable for this sample.
            var producerConfig = new ProducerConfig
            {
                BootstrapServers = "localhost:9092,localhost:9093,localhost:9094",
                MessageTimeoutMs = 5000,
            };

            // Create a producer. Set up an error handler to simply log any
            // errors to the command line.
            var producer = new ProducerBuilder<Null, string>(producerConfig)
                .SetErrorHandler((_, error) =>
                {
                    Console.WriteLine($"[ProducerError] {error.ToString()}");
                })
                .Build();

            // Produce 5 messages. Each has a delivery handler that prints the
            // message and indicator as to whether or not it was delivered
            // successfully.   
            for (var i = 0; i < 5; ++i)
            {
                producer.Produce("my-replicated-topic", new Message<Null, string>
                {
                    Value = $"Hello world {i}"
                }, (deliveryReport) =>
                {
                    if (deliveryReport.Error.IsError)
                    {
                        Console.WriteLine($"[X]: {deliveryReport.Message.Value} - {deliveryReport.Error.ToString()}");
                    }
                    else
                    {
                        Console.WriteLine($"[✓] {deliveryReport.Message.Value}");
                    }
                });
            }

            Console.WriteLine($"Flushing... (shouldn't take more than {producerConfig.MessageTimeoutMs}ms)");
            
            // Execute the flush in another task so that we can cancel it if
            // it takes too long.
            var flushTask = Task.Factory.StartNew(() => producer.Flush());
            var waitMs = producerConfig.MessageTimeoutMs * 3;
            var completed = flushTask.Wait(waitMs.Value);

            if (completed)
            {
                Console.WriteLine($"Flush completed in less than {waitMs}ms.");
            }
            else
            {
                Console.WriteLine($"Flush DID NOT complete after {waitMs}ms!");
            }
        }
    }
}

ConfluentKafkaProducerHangsOnFlush.py

from confluent_kafka import Producer
import time

p = Producer({'bootstrap.servers': 'localhost:9092,localhost:9093,localhost:9094',
              'message.timeout.ms': 5000,
              'debug': 'all'})

def delivery_report(err, msg):
    """ Called once for each message produced to indicate delivery result.
        Triggered by poll() or flush(). """
    if err is not None:
        print('|{:.3f}| Message delivery failed: {}'.format(time.time(), err))
    else:
        print('|{:.3f}| Message delivered to {} [{}]'.format(time.time(), msg.topic(), msg.partition()))

for i in range(5):
    # Trigger any available delivery report callbacks from previous produce() calls
    p.poll(0)

    # Asynchronously produce a message, the delivery report callback
    # will be triggered from poll() above, or flush() below, when the message has
    # been successfully delivered or failed permanently.
    p.produce('my-replicated-topic', 'Hello world {}'.format(i).encode('utf-8'), callback=delivery_report)

# Wait for any outstanding messages to be delivered and delivery report
# callbacks to be triggered.
print('|{:.3f}| Flushing...'.format(time.time()))
p.flush()

myproducer-2.log

%7|1565629330.705|BRKMAIN|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Enter main broker thread
%7|1565629330.705|WAKEUPFD|rdkafka#producer-1| [thrd:app]: localhost:9092/bootstrap: Enabled low-latency ops queue wake-ups
%7|1565629330.706|BROKER|rdkafka#producer-1| [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1
%7|1565629330.706|BRKMAIN|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread
%7|1565629330.706|WAKEUPFD|rdkafka#producer-1| [thrd:app]: localhost:9093/bootstrap: Enabled low-latency ops queue wake-ups
%7|1565629330.706|BROKER|rdkafka#producer-1| [thrd:app]: localhost:9093/bootstrap: Added new broker with NodeId -1
%7|1565629330.706|WAKEUPFD|rdkafka#producer-1| [thrd:app]: localhost:9094/bootstrap: Enabled low-latency ops queue wake-ups
%7|1565629330.706|BRKMAIN|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Enter main broker thread
%7|1565629330.706|BROKER|rdkafka#producer-1| [thrd:app]: localhost:9094/bootstrap: Added new broker with NodeId -1
%7|1565629330.706|CONNECT|rdkafka#producer-1| [thrd:app]: localhost:9093/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s))
%7|1565629330.706|BRKMAIN|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enter main broker thread
%7|1565629330.706|CONNECT|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Received CONNECT op
%7|1565629330.706|STATE|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Broker changed state INIT -> TRY_CONNECT
%7|1565629330.706|BROADCAST|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: Broadcasting state change
%7|1565629330.706|CONNECT|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: broker in state TRY_CONNECT connecting
%7|1565629330.706|STATE|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
%7|1565629330.706|BROADCAST|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: Broadcasting state change
%7|1565629330.706|INIT|rdkafka#producer-1| [thrd:app]: librdkafka v1.1.0 (0x10100ff) rdkafka#producer-1 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, GCC GXX PKGCONFIG OSXLD LIBDL PLUGINS ZLIB SSL SASL_CYRUS ZSTD HDRHISTOGRAM SNAPPY SOCKEM SASL_SCRAM SASL_OAUTHBEARER CRC32C_HW, debug 0xffff)
%7|1565629330.706|TOPIC|rdkafka#producer-1| [thrd:app]: New local topic: my-replicated-topic
%7|1565629330.706|TOPPARNEW|rdkafka#producer-1| [thrd:app]: NEW my-replicated-topic [-1] 0x7fddfe103dc0 (at rd_kafka_topic_new0:393)
%7|1565629330.708|CONNECT|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Connecting to ipv6#[::1]:9093 (plaintext) with socket 13
%7|1565629330.708|BROKERFAIL|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: failed: err: Local: Broker transport failure: (errno: Connection refused)
%7|1565629330.708|STATE|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Broker changed state CONNECT -> DOWN
%7|1565629330.708|BROADCAST|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: Broadcasting state change
%7|1565629330.708|BUFQ|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Purging bufq with 0 buffers
%7|1565629330.708|BUFQ|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Purging bufq with 0 buffers
%7|1565629330.708|BUFQ|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Updating 0 buffers on connection reset
%7|1565629330.708|STATE|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Broker changed state DOWN -> INIT
%7|1565629330.708|BROADCAST|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: Broadcasting state change
%7|1565629331.706|NOINFO|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic metadata information unknown
%7|1565629331.706|NOINFO|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic partition count is zero: should refresh metadata
%7|1565629331.706|CONNECT|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 0 connection attempt(s))
%7|1565629331.706|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: refresh unavailable topics
%7|1565629331.706|CONNECT|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received CONNECT op
%7|1565629331.706|STATE|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Broker changed state INIT -> TRY_CONNECT
%7|1565629331.706|BROADCAST|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: Broadcasting state change
%7|1565629331.706|CONNECT|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: broker in state TRY_CONNECT connecting
%7|1565629331.706|METADATA|rdkafka#producer-1| [thrd:main]: Skipping metadata refresh of 1 topic(s): no usable brokers
%7|1565629331.706|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection
%7|1565629331.706|STATE|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
%7|1565629331.706|BROADCAST|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: Broadcasting state change
%7|1565629331.707|CONNECT|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Connecting to ipv6#[::1]:9094 (plaintext) with socket 13
%7|1565629331.707|CONNECT|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Connected to ipv6#[::1]:9094
%7|1565629331.708|CONNECTED|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Connected (#1)
%7|1565629331.708|FEATURE|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1565629331.708|STATE|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1565629331.708|BROADCAST|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: Broadcasting state change
%7|1565629331.708|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent ApiVersionRequest (v0, 25 bytes @ 0, CorrId 1)
%7|1565629331.709|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received ApiVersionResponse (v0, 276 bytes, CorrId 1, rtt 1.26ms)
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Broker API support:
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey Produce (0) Versions 0..7
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey Fetch (1) Versions 0..11
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey Offset (2) Versions 0..5
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey Metadata (3) Versions 0..8
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey LeaderAndIsr (4) Versions 0..2
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey StopReplica (5) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey UpdateMetadata (6) Versions 0..5
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey ControlledShutdown (7) Versions 0..2
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey OffsetCommit (8) Versions 0..7
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey OffsetFetch (9) Versions 0..5
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey GroupCoordinator (10) Versions 0..2
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey JoinGroup (11) Versions 0..5
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey Heartbeat (12) Versions 0..3
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey LeaveGroup (13) Versions 0..2
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey SyncGroup (14) Versions 0..3
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey DescribeGroups (15) Versions 0..3
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey ListGroups (16) Versions 0..2
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey SaslHandshake (17) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey ApiVersion (18) Versions 0..2
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey CreateTopics (19) Versions 0..3
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey DeleteTopics (20) Versions 0..3
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey DeleteRecords (21) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey InitProducerId (22) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey EndTxn (26) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey TxnOffsetCommit (28) Versions 0..2
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey DescribeAcls (29) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey CreateAcls (30) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey DeleteAcls (31) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey DescribeConfigs (32) Versions 0..2
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey AlterConfigs (33) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey AlterReplicaLogDirs (34) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey DescribeLogDirs (35) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey SaslAuthenticate (36) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey CreatePartitions (37) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey CreateDelegationToken (38) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey RenewDelegationToken (39) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey ExpireDelegationToken (40) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey DescribeDelegationToken (41) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey DeleteGroups (42) Versions 0..1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey Unknown-43? (43) Versions 0..0
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey Unknown-44? (44) Versions 0..0
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature MsgVer1
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature MsgVer2
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature ApiVersion
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature BrokerGroupCoordinator
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature BrokerBalancedConsumer
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature ThrottleTime
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature Sasl
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature SaslHandshake
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature LZ4
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature OffsetTime
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature IdempotentProducer
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature ZSTD: Produce (7..7) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature ZSTD: Fetch (10..10) supported by broker
%7|1565629331.709|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature ZSTD
%7|1565629331.709|FEATURE|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD
%7|1565629331.709|STATE|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Broker changed state APIVERSION_QUERY -> UP
%7|1565629331.709|BROADCAST|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: Broadcasting state change
%7|1565629331.709|METADATA|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: Hinted cache of 1/1 topic(s) being queried
%7|1565629331.709|METADATA|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: Requesting metadata for 1/1 topics: connected
%7|1565629331.709|METADATA|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Request metadata for 1 topic(s): connected
%7|1565629331.709|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 2)
%7|1565629331.710|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 2, rtt 0.38ms)
%7|1565629331.710|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): connected =====
%7|1565629331.710|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629331.710|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629331.710|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629331.710|WAKEUPFD|rdkafka#producer-1| [thrd:main]: 172.16.22.33:9094/2: Enabled low-latency ops queue wake-ups
%7|1565629331.710|BROKER|rdkafka#producer-1| [thrd:main]: 172.16.22.33:9094/2: Added new broker with NodeId 2
%7|1565629331.710|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629331.710|STATE|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic changed state unknown -> exists
%7|1565629331.710|PARTCNT|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic partition count changed from 0 to 1
%7|1565629331.710|TOPPARNEW|rdkafka#producer-1| [thrd:main]: NEW my-replicated-topic [0] 0x7fddfb525b50 (at rd_kafka_topic_partition_cnt_update:620)
%7|1565629331.710|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629331.710|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 2, remove 0)
%7|1565629331.710|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: broker :0/internal is now leader for partition with 0 messages (0 bytes) queued
%7|1565629331.710|BRKMIGR|rdkafka#producer-1| [thrd:main]: Migrating topic my-replicated-topic [0] 0x7fddfb525b50 from (none) to :0/internal (sending PARTITION_JOIN to :0/internal)
%7|1565629331.710|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 5 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629331.710|TOPBRK|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Topic my-replicated-topic [0]: joining broker (rktp 0x7fddfb525b50, 0 message(s) queued)
%7|1565629331.710|FETCHADD|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Added my-replicated-topic [0] to active list (1 entries, opv 0, 0 messages queued)
%7|1565629331.710|BRKMAIN|rdkafka#producer-1| [thrd:172.16.22.33:9094/2]: 172.16.22.33:9094/2: Enter main broker thread
%7|1565629331.710|BROADCAST|rdkafka#producer-1| [thrd::0/internal]: Broadcasting state change
%7|1565629331.710|UAS|rdkafka#producer-1| [thrd:main]: 5/5 messages were partitioned in topic my-replicated-topic
%7|1565629331.710|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629331.710|CLUSTERID|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId update "" -> "Grf0KqAdRGKnqq_GmNI6yw"
%7|1565629331.710|CONTROLLERID|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ControllerId update -1 -> 2
%7|1565629331.710|BROADCAST|rdkafka#producer-1| [thrd:main]: Broadcasting state change
%7|1565629332.708|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629332.708|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629332.708|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629332.708|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 3)
%7|1565629332.709|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 3, rtt 0.47ms)
%7|1565629332.709|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629332.709|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629332.709|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629332.709|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629332.709|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629332.709|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629332.709|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629332.709|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629332.709|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629332.709|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629332.709|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629333.712|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629333.712|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629333.712|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629333.712|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 4)
%7|1565629333.713|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 4, rtt 0.43ms)
%7|1565629333.713|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629333.713|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629333.713|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629333.713|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629333.713|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629333.713|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629333.713|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629333.713|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629333.713|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629333.713|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629333.713|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629334.715|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629334.715|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629334.716|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629334.716|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 5)
%7|1565629334.716|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 5, rtt 0.44ms)
%7|1565629334.716|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629334.716|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629334.716|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629334.716|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629334.716|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629334.716|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629334.716|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629334.716|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629334.716|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629334.716|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629334.716|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629335.716|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629335.716|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629335.716|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629335.716|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 6)
%7|1565629335.717|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 6, rtt 0.44ms)
%7|1565629335.717|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629335.717|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629335.717|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629335.717|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629335.717|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629335.717|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629335.717|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629335.717|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629335.717|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629335.717|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629335.717|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629336.720|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629336.764|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629336.764|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629336.764|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 7)
%7|1565629336.765|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 7, rtt 0.46ms)
%7|1565629336.765|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629336.765|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629336.765|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629336.765|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629336.765|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629336.765|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629336.765|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629336.765|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629336.765|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629336.765|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629336.765|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629337.768|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629337.768|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629337.768|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629337.768|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 8)
%7|1565629337.769|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 8, rtt 0.50ms)
%7|1565629337.769|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629337.769|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629337.769|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629337.769|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629337.769|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629337.769|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629337.769|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629337.769|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629337.769|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629337.769|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629337.769|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629338.768|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629338.768|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629338.769|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629338.769|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 9)
%7|1565629338.769|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 9, rtt 0.45ms)
%7|1565629338.769|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629338.769|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629338.769|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629338.769|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629338.769|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629338.769|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629338.769|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629338.769|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629338.769|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629338.769|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629338.769|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629339.770|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629339.770|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629339.770|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629339.770|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 10)
%7|1565629339.771|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 10, rtt 0.43ms)
%7|1565629339.771|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629339.771|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629339.771|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629339.771|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629339.771|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629339.771|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629339.771|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629339.771|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629339.771|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629339.771|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629339.771|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629340.773|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629340.773|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629340.773|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629340.773|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 11)
%7|1565629340.774|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 11, rtt 0.44ms)
%7|1565629340.774|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629340.774|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629340.774|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629340.774|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629340.774|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629340.774|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629340.774|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629340.774|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629340.774|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629340.774|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629340.774|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629341.774|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629341.774|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629341.774|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629341.774|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 12)
%7|1565629341.774|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 12, rtt 0.47ms)
%7|1565629341.774|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629341.774|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629341.774|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629341.774|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629341.774|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629341.774|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629341.774|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629341.774|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629341.774|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629341.774|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629341.774|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629342.776|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629342.776|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629342.776|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629342.776|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 13)
%7|1565629342.776|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 13, rtt 0.45ms)
%7|1565629342.776|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629342.776|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629342.776|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629342.776|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629342.776|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629342.776|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629342.776|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629342.776|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629342.776|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629342.776|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629342.776|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629343.778|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629343.778|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629343.778|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629343.778|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 14)
%7|1565629343.779|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 14, rtt 0.48ms)
%7|1565629343.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629343.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629343.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629343.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629343.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629343.779|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629343.779|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629343.779|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629343.779|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629343.779|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629343.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629344.779|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629344.779|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629344.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629344.779|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 15)
%7|1565629344.779|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 15, rtt 0.42ms)
%7|1565629344.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629344.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629344.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629344.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629344.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629344.779|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629344.779|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629344.779|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629344.779|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629344.779|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629344.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629345.779|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629345.779|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629345.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629345.779|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 16)
%7|1565629345.779|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 16, rtt 0.45ms)
%7|1565629345.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629345.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629345.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629345.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629345.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629345.779|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629345.779|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629345.779|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629345.779|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629345.779|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629345.779|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629346.780|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629346.780|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629346.780|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629346.780|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 17)
%7|1565629346.780|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 17, rtt 0.40ms)
%7|1565629346.780|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629346.780|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629346.780|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629346.780|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629346.780|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629346.780|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629346.780|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629346.780|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629346.780|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629346.780|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629346.780|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629347.784|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629347.784|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629347.784|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629347.784|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 18)
%7|1565629347.785|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 18, rtt 0.44ms)
%7|1565629347.785|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629347.785|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629347.785|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629347.785|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629347.785|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629347.785|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629347.785|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629347.785|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629347.785|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629347.785|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629347.785|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629348.788|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629348.788|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629348.788|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629348.788|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 19)
%7|1565629348.788|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 19, rtt 0.45ms)
%7|1565629348.788|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629348.788|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629348.788|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629348.788|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629348.789|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629348.789|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629348.789|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629348.789|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629348.789|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629348.789|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629348.789|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629349.788|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629349.788|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629349.788|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629349.788|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 20)
%7|1565629349.789|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 20, rtt 0.50ms)
%7|1565629349.789|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629349.789|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629349.789|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629349.789|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629349.789|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629349.789|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629349.789|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629349.789|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629349.789|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629349.789|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629349.789|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629350.793|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629350.793|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629350.793|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629350.793|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 21)
%7|1565629350.793|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 21, rtt 0.44ms)
%7|1565629350.793|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629350.793|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629350.793|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629350.793|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629350.793|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629350.793|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629350.793|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629350.793|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629350.793|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629350.793|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629350.793|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629351.793|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629351.793|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629351.793|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629351.793|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 22)
%7|1565629351.794|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 22, rtt 0.50ms)
%7|1565629351.794|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629351.794|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629351.794|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629351.794|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629351.794|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629351.794|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629351.794|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629351.794|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629351.794|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629351.794|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629351.794|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629352.798|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629352.798|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629352.798|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629352.798|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 23)
%7|1565629352.798|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 23, rtt 0.49ms)
%7|1565629352.798|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629352.798|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629352.798|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629352.799|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629352.799|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629352.799|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629352.799|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629352.799|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629352.799|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629352.799|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629352.799|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629353.800|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629353.800|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629353.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629353.800|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 24)
%7|1565629353.800|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 24, rtt 0.50ms)
%7|1565629353.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629353.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629353.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629353.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629353.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629353.800|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629353.800|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629353.800|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629353.800|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629353.800|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629353.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629354.800|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629354.800|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629354.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629354.800|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 25)
%7|1565629354.800|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 25, rtt 0.44ms)
%7|1565629354.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629354.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629354.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629354.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629354.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629354.800|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629354.800|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629354.800|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629354.800|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629354.800|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629354.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629355.800|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629355.800|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629355.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629355.800|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 26)
%7|1565629355.800|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 26, rtt 0.44ms)
%7|1565629355.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629355.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629355.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629355.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629355.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629355.800|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629355.800|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629355.800|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629355.800|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629355.800|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629355.800|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629356.803|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629356.803|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629356.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629356.803|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 27)
%7|1565629356.803|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 27, rtt 0.44ms)
%7|1565629356.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629356.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629356.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629356.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629356.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629356.803|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629356.803|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629356.803|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629356.803|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629356.803|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629356.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629357.803|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629357.803|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629357.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629357.803|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 28)
%7|1565629357.803|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 28, rtt 0.52ms)
%7|1565629357.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629357.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629357.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629357.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629357.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629357.803|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629357.803|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629357.803|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629357.803|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629357.803|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629357.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629358.803|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629358.803|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629358.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629358.803|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 29)
%7|1565629358.803|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 29, rtt 0.42ms)
%7|1565629358.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629358.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629358.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629358.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629358.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629358.803|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629358.803|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629358.803|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629358.803|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629358.803|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629358.803|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629359.804|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629359.804|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629359.804|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629359.804|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 30)
%7|1565629359.804|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 30, rtt 0.42ms)
%7|1565629359.804|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629359.804|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629359.804|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629359.804|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629359.804|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629359.804|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629359.804|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629359.804|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629359.804|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629359.804|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629359.804|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629360.804|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629360.804|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629360.804|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629360.804|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 31)
%7|1565629360.804|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 31, rtt 0.43ms)
%7|1565629360.804|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629360.804|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629360.804|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629360.804|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629360.804|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629360.804|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629360.804|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629360.804|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629360.804|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629360.804|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629360.804|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629361.808|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629361.808|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629361.808|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629361.808|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 32)
%7|1565629361.808|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 32, rtt 0.38ms)
%7|1565629361.808|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629361.808|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629361.808|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629361.808|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629361.808|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629361.808|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629361.808|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629361.808|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629361.808|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629361.808|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629361.808|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629362.811|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629362.869|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629362.869|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629362.870|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 33)
%7|1565629362.870|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 33, rtt 0.38ms)
%7|1565629362.870|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629362.870|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629362.870|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629362.870|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629362.870|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629362.870|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629362.870|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629362.870|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629362.870|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629362.870|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629362.870|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629363.871|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629363.871|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629363.871|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629363.871|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 34)
%7|1565629363.871|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 34, rtt 0.45ms)
%7|1565629363.871|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629363.871|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629363.871|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565629363.871|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565629363.871|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629363.871|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629363.871|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629363.871|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629363.871|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629363.871|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629363.871|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629364.873|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629364.912|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629364.912|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629364.912|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 35)
%7|1565629364.913|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 138 bytes, CorrId 35, rtt 0.54ms)
%7|1565629364.913|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629364.913|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629365.004|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 2 brokers, 1 topics
%7|1565629365.004|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/2: 172.16.22.33:9092 NodeId 0
%7|1565629365.004|WAKEUPFD|rdkafka#producer-1| [thrd:main]: 172.16.22.33:9092/0: Enabled low-latency ops queue wake-ups
%7|1565629365.004|BROKER|rdkafka#producer-1| [thrd:main]: 172.16.22.33:9092/0: Added new broker with NodeId 0
%7|1565629365.004|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #1/2: 172.16.22.33:9094 NodeId 2
%7|1565629365.004|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629365.004|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565629365.004|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629365.004|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565629365.004|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629365.004|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629365.004|BRKMAIN|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: 172.16.22.33:9092/0: Enter main broker thread
%7|1565629365.004|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629365.912|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565629365.912|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565629365.912|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565629365.912|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 36)
%7|1565629365.913|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 142 bytes, CorrId 36, rtt 0.44ms)
%7|1565629365.913|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565629365.913|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565629365.913|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 2 brokers, 1 topics
%7|1565629365.913|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/2: 172.16.22.33:9092 NodeId 0
%7|1565629365.913|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #1/2: 172.16.22.33:9094 NodeId 2
%7|1565629365.913|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565629365.913|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader 0
%7|1565629365.913|TOPICUPD|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0] migrated from broker -1 to 0
%7|1565629365.913|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker 172.16.22.33:9092/0 (rktp 0x7fddfb525b50, term 0, ref 3, remove 0)
%7|1565629365.913|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: broker :0/internal no longer leader
%7|1565629365.913|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: broker 172.16.22.33:9092/0 is now leader for partition with 5 messages (65 bytes) queued
%7|1565629365.913|BRKMIGR|rdkafka#producer-1| [thrd:main]: Migrating topic my-replicated-topic [0] 0x7fddfb525b50 from :0/internal to 172.16.22.33:9092/0 (sending PARTITION_LEAVE to :0/internal)
%7|1565629365.913|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565629365.913|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565629365.913|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565629365.913|TOPBRK|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Topic my-replicated-topic [0]: leaving broker (0 messages in xmitq, next leader 172.16.22.33:9092/0, rktp 0x7fddfb525b50)
%7|1565629365.913|FETCHADD|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Removed my-replicated-topic [0] from active list (0 entries, opv 0)
%7|1565629365.913|BROADCAST|rdkafka#producer-1| [thrd::0/internal]: Broadcasting state change
%7|1565629365.913|TOPBRK|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: 172.16.22.33:9092/0: Topic my-replicated-topic [0]: joining broker (rktp 0x7fddfb525b50, 5 message(s) queued)
%7|1565629365.913|FETCHADD|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: 172.16.22.33:9092/0: Added my-replicated-topic [0] to active list (1 entries, opv 0, 5 messages queued)
%7|1565629365.913|BROADCAST|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: Broadcasting state change
%7|1565629365.913|TIMEOUT|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: 172.16.22.33:9092/0: my-replicated-topic [0]: timed out 0+5 message(s) (MsgId 1..5): message.timeout.ms exceeded
%7|1565629365.915|DESTROY|rdkafka#producer-1| [thrd:app]: Terminating instance (destroy flags none (0x0))
%7|1565629365.915|TERMINATE|rdkafka#producer-1| [thrd:app]: Interrupting timers
%7|1565629365.915|TERMINATE|rdkafka#producer-1| [thrd:app]: Sending TERMINATE to internal main thread
%7|1565629365.915|TERMINATE|rdkafka#producer-1| [thrd:app]: Joining internal main thread
%7|1565629365.915|TERMINATE|rdkafka#producer-1| [thrd:main]: Internal main thread terminating
%7|1565629365.915|DESTROY|rdkafka#producer-1| [thrd:main]: Destroy internal
%7|1565629365.915|BROADCAST|rdkafka#producer-1| [thrd:main]: Broadcasting state change
%7|1565629365.915|DESTROY|rdkafka#producer-1| [thrd:main]: Removing all topics
%7|1565629365.915|PARTCNT|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic partition count changed from 1 to 0
%7|1565629365.915|REMOVE|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0] no longer reported in metadata
%7|1565629365.915|BRKMIGR|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0] 0x7fddfb525b50 sending final LEAVE for removal by 172.16.22.33:9092/0
%7|1565629365.915|TOPPARREMOVE|rdkafka#producer-1| [thrd:main]: Removing toppar my-replicated-topic [-1] 0x7fddfe103dc0
%7|1565629365.915|TOPBRK|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: 172.16.22.33:9092/0: Topic my-replicated-topic [0]: leaving broker (0 messages in xmitq, next leader (none), rktp 0x7fddfb525b50)
%7|1565629365.915|DESTROY|rdkafka#producer-1| [thrd:main]: my-replicated-topic [-1]: 0x7fddfe103dc0 DESTROY_FINAL
%7|1565629365.915|FETCHADD|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: 172.16.22.33:9092/0: Removed my-replicated-topic [0] from active list (0 entries, opv 0)
%7|1565629365.915|DESTROY|rdkafka#producer-1| [thrd:main]: Sending TERMINATE to 172.16.22.33:9092/0
%7|1565629365.915|TOPBRK|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: 172.16.22.33:9092/0: Topic my-replicated-topic [0]: no next leader, failing 0 message(s) in partition queue
%7|1565629365.915|BROADCAST|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: Broadcasting state change
%7|1565629365.915|TOPPARREMOVE|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: Removing toppar my-replicated-topic [0] 0x7fddfb525b50
%7|1565629365.915|DESTROY|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: my-replicated-topic [0]: 0x7fddfb525b50 DESTROY_FINAL
%7|1565629365.915|DESTROY|rdkafka#producer-1| [thrd:main]: Sending TERMINATE to 172.16.22.33:9094/2
%7|1565629365.915|TERM|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: 172.16.22.33:9092/0: Received TERMINATE op in state INIT: 1 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1565629365.915|BROKERFAIL|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: 172.16.22.33:9092/0: failed: err: Local: Broker handle destroyed: (errno: Undefined error: 0)
%7|1565629365.915|FAIL|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: 172.16.22.33:9092/0: Client is terminating (after 911ms in state INIT)
%7|1565629365.915|STATE|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: 172.16.22.33:9092/0: Broker changed state INIT -> DOWN
%7|1565629365.915|BROADCAST|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: Broadcasting state change
%7|1565629365.915|TERM|rdkafka#producer-1| [thrd:172.16.22.33:9094/2]: 172.16.22.33:9094/2: Received TERMINATE op in state INIT: 1 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1565629365.915|BROKERFAIL|rdkafka#producer-1| [thrd:172.16.22.33:9094/2]: 172.16.22.33:9094/2: failed: err: Local: Broker handle destroyed: (errno: strerror_r(316) failed (ret 22))
%7|1565629365.915|FAIL|rdkafka#producer-1| [thrd:172.16.22.33:9094/2]: 172.16.22.33:9094/2: Client is terminating (after 34205ms in state INIT)
%7|1565629365.915|STATE|rdkafka#producer-1| [thrd:172.16.22.33:9094/2]: 172.16.22.33:9094/2: Broker changed state INIT -> DOWN
%7|1565629365.915|BROADCAST|rdkafka#producer-1| [thrd:172.16.22.33:9094/2]: Broadcasting state change
%7|1565629365.915|DESTROY|rdkafka#producer-1| [thrd:main]: Sending TERMINATE to localhost:9094/bootstrap
%7|1565629365.915|BUFQ|rdkafka#producer-1| [thrd:172.16.22.33:9094/2]: 172.16.22.33:9094/2: Purging bufq with 0 buffers
%7|1565629365.915|BUFQ|rdkafka#producer-1| [thrd:172.16.22.33:9094/2]: 172.16.22.33:9094/2: Purging bufq with 0 buffers
%7|1565629365.915|DESTROY|rdkafka#producer-1| [thrd:main]: Sending TERMINATE to localhost:9093/bootstrap
%7|1565629365.915|BUFQ|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: 172.16.22.33:9092/0: Purging bufq with 0 buffers
%7|1565629365.915|DESTROY|rdkafka#producer-1| [thrd:main]: Sending TERMINATE to localhost:9092/bootstrap
%7|1565629365.915|BUFQ|rdkafka#producer-1| [thrd:172.16.22.33:9094/2]: 172.16.22.33:9094/2: Updating 0 buffers on connection reset
%7|1565629365.915|TERM|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Received TERMINATE op in state INIT: 1 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1565629365.915|TERMINATE|rdkafka#producer-1| [thrd:172.16.22.33:9094/2]: 172.16.22.33:9094/2: Handle is terminating in state DOWN: 1 refcnts (0x7fddfd029b28), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1565629365.915|BROKERFAIL|rdkafka#producer-1| [thrd:172.16.22.33:9094/2]: 172.16.22.33:9094/2: failed: err: Local: Broker handle destroyed: (errno: strerror_r(316) failed (ret 22))
%7|1565629365.915|BUFQ|rdkafka#producer-1| [thrd:172.16.22.33:9094/2]: 172.16.22.33:9094/2: Purging bufq with 0 buffers
%7|1565629365.915|BUFQ|rdkafka#producer-1| [thrd:172.16.22.33:9094/2]: 172.16.22.33:9094/2: Purging bufq with 0 buffers
%7|1565629365.915|BUFQ|rdkafka#producer-1| [thrd:172.16.22.33:9094/2]: 172.16.22.33:9094/2: Updating 0 buffers on connection reset
%7|1565629365.915|TERM|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received TERMINATE op in state UP: 1 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1565629365.915|BROKERFAIL|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: failed: err: Local: Broker handle destroyed: (errno: Resource temporarily unavailable)
%7|1565629365.915|TERMINATE|rdkafka#producer-1| [thrd:main]: Purging reply queue
%7|1565629365.915|TERM|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received TERMINATE op in state INIT: 1 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1565629365.915|BROKERFAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: failed: err: Local: Broker handle destroyed: (errno: strerror_r(316) failed (ret 22))
%7|1565629365.915|FAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Client is terminating (after 35209ms in state INIT)
%7|1565629365.915|TERMINATE|rdkafka#producer-1| [thrd:main]: Decommissioning internal broker
%7|1565629365.915|FAIL|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Client is terminating (after 34206ms in state UP)
%7|1565629365.916|STATE|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Broker changed state UP -> DOWN
%7|1565629365.916|BROADCAST|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: Broadcasting state change
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Purging bufq with 0 buffers
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Purging bufq with 0 buffers
%7|1565629365.916|TERM|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 1 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1565629365.915|BROKERFAIL|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: failed: err: Local: Broker handle destroyed: (errno: strerror_r(316) failed (ret 22))
%7|1565629365.915|BUFQ|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: 172.16.22.33:9092/0: Purging bufq with 0 buffers
%7|1565629365.915|STATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> DOWN
%7|1565629365.916|BROADCAST|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: Broadcasting state change
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
%7|1565629365.916|FAIL|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Client is terminating (after 35207ms in state INIT)
%7|1565629365.916|STATE|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Broker changed state INIT -> DOWN
%7|1565629365.916|BROADCAST|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: Broadcasting state change
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Purging bufq with 0 buffers
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Purging bufq with 0 buffers
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Updating 0 buffers on connection reset
%7|1565629365.916|TERMINATE|rdkafka#producer-1| [thrd:main]: Join 6 broker thread(s)
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Updating 0 buffers on connection reset
%7|1565629365.916|TERMINATE|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Handle is terminating in state DOWN: 1 refcnts (0x7fddfc002d28), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1565629365.916|BROKERFAIL|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: failed: err: Local: Broker handle destroyed: (errno: Resource temporarily unavailable)
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: 172.16.22.33:9092/0: Updating 0 buffers on connection reset
%7|1565629365.916|TERMINATE|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Handle is terminating in state DOWN: 1 refcnts (0x7fddff00c128), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1565629365.916|BROKERFAIL|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: failed: err: Local: Broker handle destroyed: (errno: strerror_r(316) failed (ret 22))
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Purging bufq with 0 buffers
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Purging bufq with 0 buffers
%7|1565629365.916|TERMINATE|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Handle is terminating in state DOWN: 1 refcnts (0x7fddfd025f28), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1565629365.916|BROKERFAIL|rdkafka#producer-1| [thrd::0/internal]: :0/internal: failed: err: Local: Broker handle destroyed: (errno: strerror_r(316) failed (ret 22))
%7|1565629365.916|FAIL|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Client is terminating (after 35210ms in state INIT)
%7|1565629365.916|STATE|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN
%7|1565629365.916|BROADCAST|rdkafka#producer-1| [thrd::0/internal]: Broadcasting state change
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Updating 0 buffers on connection reset
%7|1565629365.916|TERMINATE|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 1 refcnts (0x7fddfd025328), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1565629365.916|BROKERFAIL|rdkafka#producer-1| [thrd::0/internal]: :0/internal: failed: err: Local: Broker handle destroyed: (errno: strerror_r(316) failed (ret 22))
%7|1565629365.916|BROKERFAIL|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: failed: err: Local: Broker handle destroyed: (errno: strerror_r(316) failed (ret 22))
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Purging bufq with 0 buffers
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Purging bufq with 0 buffers
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Updating 0 buffers on connection reset
%7|1565629365.916|TERMINATE|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: 172.16.22.33:9092/0: Handle is terminating in state DOWN: 1 refcnts (0x7fddff00ed28), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1565629365.916|BROKERFAIL|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: 172.16.22.33:9092/0: failed: err: Local: Broker handle destroyed: (errno: Undefined error: 0)
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: 172.16.22.33:9092/0: Purging bufq with 0 buffers
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: 172.16.22.33:9092/0: Purging bufq with 0 buffers
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:172.16.22.33:9092/0]: 172.16.22.33:9092/0: Updating 0 buffers on connection reset
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Updating 0 buffers on connection reset
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset
%7|1565629365.916|BUFQ|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Updating 0 buffers on connection reset
%7|1565629365.916|TERMINATE|rdkafka#producer-1| [thrd:main]: Internal main thread termination done
%7|1565629365.916|TERMINATE|rdkafka#producer-1| [thrd:app]: Destroying op queues
%7|1565629365.916|TERMINATE|rdkafka#producer-1| [thrd:app]: Termination done: freeing resources

pyproducer.log

%7|1565626772.272|WAKEUPFD|rdkafka#producer-1| [thrd:app]: localhost:9092/bootstrap: Enabled low-latency ops queue wake-ups
%7|1565626772.272|BRKMAIN|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Enter main broker thread
%7|1565626772.272|BROKER|rdkafka#producer-1| [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1
%7|1565626772.272|BRKMAIN|rdkafka#producer-1| [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread
%7|1565626772.272|WAKEUPFD|rdkafka#producer-1| [thrd:app]: localhost:9093/bootstrap: Enabled low-latency ops queue wake-ups
%7|1565626772.272|BROKER|rdkafka#producer-1| [thrd:app]: localhost:9093/bootstrap: Added new broker with NodeId -1
%7|1565626772.272|WAKEUPFD|rdkafka#producer-1| [thrd:app]: localhost:9094/bootstrap: Enabled low-latency ops queue wake-ups
%7|1565626772.273|BROKER|rdkafka#producer-1| [thrd:app]: localhost:9094/bootstrap: Added new broker with NodeId -1
%7|1565626772.273|BRKMAIN|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Enter main broker thread
%7|1565626772.273|BRKMAIN|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enter main broker thread
%7|1565626772.273|CONNECT|rdkafka#producer-1| [thrd:app]: localhost:9093/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s))
%7|1565626772.273|INIT|rdkafka#producer-1| [thrd:app]: librdkafka v1.1.0 (0x10100ff) rdkafka#producer-1 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, GCC GXX PKGCONFIG OSXLD LIBDL PLUGINS ZLIB SSL SASL_CYRUS ZSTD HDRHISTOGRAM SNAPPY SOCKEM SASL_SCRAM SASL_OAUTHBEARER CRC32C_HW, debug 0xffff)
%7|1565626772.273|CONNECT|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Received CONNECT op
%7|1565626772.273|STATE|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Broker changed state INIT -> TRY_CONNECT
%7|1565626772.273|BROADCAST|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: Broadcasting state change
%7|1565626772.273|CONNECT|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: broker in state TRY_CONNECT connecting
%7|1565626772.273|STATE|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
%7|1565626772.273|BROADCAST|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: Broadcasting state change
%7|1565626772.273|TOPIC|rdkafka#producer-1| [thrd:app]: New local topic: my-replicated-topic
%7|1565626772.273|TOPPARNEW|rdkafka#producer-1| [thrd:app]: NEW my-replicated-topic [-1] 0x7fb6adf43830 (at rd_kafka_topic_new0:393)
%7|1565626772.275|CONNECT|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Connecting to ipv6#[::1]:9093 (plaintext) with socket 13
%7|1565626772.275|BROKERFAIL|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: failed: err: Local: Broker transport failure: (errno: Connection refused)
%7|1565626772.275|STATE|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Broker changed state CONNECT -> DOWN
%7|1565626772.275|BROADCAST|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: Broadcasting state change
%7|1565626772.275|BUFQ|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Purging bufq with 0 buffers
%7|1565626772.275|BUFQ|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Purging bufq with 0 buffers
%7|1565626772.275|BUFQ|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Updating 0 buffers on connection reset
%7|1565626772.275|STATE|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: localhost:9093/bootstrap: Broker changed state DOWN -> INIT
%7|1565626772.275|BROADCAST|rdkafka#producer-1| [thrd:localhost:9093/bootstrap]: Broadcasting state change
%7|1565626773.276|NOINFO|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic metadata information unknown
%7|1565626773.276|NOINFO|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic partition count is zero: should refresh metadata
%7|1565626773.276|CONNECT|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 0 connection attempt(s))
%7|1565626773.276|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: refresh unavailable topics
%7|1565626773.276|METADATA|rdkafka#producer-1| [thrd:main]: Skipping metadata refresh of 1 topic(s): no usable brokers
%7|1565626773.276|CONNECT|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received CONNECT op
%7|1565626773.277|STATE|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Broker changed state INIT -> TRY_CONNECT
%7|1565626773.277|BROADCAST|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: Broadcasting state change
%7|1565626773.277|CONNECT|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: broker in state TRY_CONNECT connecting
%7|1565626773.276|CONNECT|rdkafka#producer-1| [thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection
%7|1565626773.277|STATE|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
%7|1565626773.277|BROADCAST|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: Broadcasting state change
%7|1565626773.277|CONNECT|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Connecting to ipv6#[::1]:9094 (plaintext) with socket 13
%7|1565626773.277|CONNECT|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Connected to ipv6#[::1]:9094
%7|1565626773.277|CONNECTED|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Connected (#1)
%7|1565626773.277|FEATURE|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1565626773.277|STATE|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1565626773.277|BROADCAST|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: Broadcasting state change
%7|1565626773.278|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent ApiVersionRequest (v0, 25 bytes @ 0, CorrId 1)
%7|1565626773.279|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received ApiVersionResponse (v0, 276 bytes, CorrId 1, rtt 1.24ms)
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Broker API support:
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey Produce (0) Versions 0..7
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey Fetch (1) Versions 0..11
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey Offset (2) Versions 0..5
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey Metadata (3) Versions 0..8
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey LeaderAndIsr (4) Versions 0..2
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey StopReplica (5) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey UpdateMetadata (6) Versions 0..5
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey ControlledShutdown (7) Versions 0..2
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey OffsetCommit (8) Versions 0..7
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey OffsetFetch (9) Versions 0..5
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey GroupCoordinator (10) Versions 0..2
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey JoinGroup (11) Versions 0..5
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey Heartbeat (12) Versions 0..3
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey LeaveGroup (13) Versions 0..2
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey SyncGroup (14) Versions 0..3
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey DescribeGroups (15) Versions 0..3
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey ListGroups (16) Versions 0..2
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey SaslHandshake (17) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey ApiVersion (18) Versions 0..2
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey CreateTopics (19) Versions 0..3
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey DeleteTopics (20) Versions 0..3
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey DeleteRecords (21) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey InitProducerId (22) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey OffsetForLeaderEpoch (23) Versions 0..3
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey AddPartitionsToTxn (24) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey AddOffsetsToTxn (25) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey EndTxn (26) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey WriteTxnMarkers (27) Versions 0..0
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey TxnOffsetCommit (28) Versions 0..2
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey DescribeAcls (29) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey CreateAcls (30) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey DeleteAcls (31) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey DescribeConfigs (32) Versions 0..2
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey AlterConfigs (33) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey AlterReplicaLogDirs (34) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey DescribeLogDirs (35) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey SaslAuthenticate (36) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey CreatePartitions (37) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey CreateDelegationToken (38) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey RenewDelegationToken (39) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey ExpireDelegationToken (40) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey DescribeDelegationToken (41) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey DeleteGroups (42) Versions 0..1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey Unknown-43? (43) Versions 0..0
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:   ApiKey Unknown-44? (44) Versions 0..0
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature MsgVer1
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature MsgVer2
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature ApiVersion
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature BrokerGroupCoordinator: GroupCoordinator (0..0) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature BrokerGroupCoordinator
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature BrokerBalancedConsumer: GroupCoordinator (0..0) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature BrokerBalancedConsumer
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature ThrottleTime
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature Sasl
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature SaslHandshake
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature LZ4: GroupCoordinator (0..0) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature LZ4
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature OffsetTime
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature IdempotentProducer
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature ZSTD: Produce (7..7) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap:  Feature ZSTD: Fetch (10..10) supported by broker
%7|1565626773.279|APIVERSION|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Enabling feature ZSTD
%7|1565626773.279|FEATURE|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD
%7|1565626773.279|STATE|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Broker changed state APIVERSION_QUERY -> UP
%7|1565626773.279|BROADCAST|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: Broadcasting state change
%7|1565626773.279|METADATA|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: Hinted cache of 1/1 topic(s) being queried
%7|1565626773.279|METADATA|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: Requesting metadata for 1/1 topics: connected
%7|1565626773.279|METADATA|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Request metadata for 1 topic(s): connected
%7|1565626773.279|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 2)
%7|1565626773.280|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 2, rtt 0.42ms)
%7|1565626773.280|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): connected =====
%7|1565626773.280|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626773.280|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626773.280|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626773.280|WAKEUPFD|rdkafka#producer-1| [thrd:main]: 172.16.22.33:9094/2: Enabled low-latency ops queue wake-ups
%7|1565626773.280|BROKER|rdkafka#producer-1| [thrd:main]: 172.16.22.33:9094/2: Added new broker with NodeId 2
%7|1565626773.280|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626773.280|STATE|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic changed state unknown -> exists
%7|1565626773.280|PARTCNT|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic partition count changed from 0 to 1
%7|1565626773.280|BRKMAIN|rdkafka#producer-1| [thrd:172.16.22.33:9094/2]: 172.16.22.33:9094/2: Enter main broker thread
%7|1565626773.280|TOPPARNEW|rdkafka#producer-1| [thrd:main]: NEW my-replicated-topic [0] 0x7fb6add0fdf0 (at rd_kafka_topic_partition_cnt_update:620)
%7|1565626773.280|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626773.280|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 2, remove 0)
%7|1565626773.280|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: broker :0/internal is now leader for partition with 0 messages (0 bytes) queued
%7|1565626773.280|BRKMIGR|rdkafka#producer-1| [thrd:main]: Migrating topic my-replicated-topic [0] 0x7fb6add0fdf0 from (none) to :0/internal (sending PARTITION_JOIN to :0/internal)
%7|1565626773.280|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 5 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626773.280|TOPBRK|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Topic my-replicated-topic [0]: joining broker (rktp 0x7fb6add0fdf0, 0 message(s) queued)
%7|1565626773.280|FETCHADD|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Added my-replicated-topic [0] to active list (1 entries, opv 0, 0 messages queued)
%7|1565626773.280|BROADCAST|rdkafka#producer-1| [thrd::0/internal]: Broadcasting state change
%7|1565626773.280|UAS|rdkafka#producer-1| [thrd:main]: 5/5 messages were partitioned in topic my-replicated-topic
%7|1565626773.280|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565626773.280|CLUSTERID|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId update "" -> "Grf0KqAdRGKnqq_GmNI6yw"
%7|1565626773.280|CONTROLLERID|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ControllerId update -1 -> 2
%7|1565626773.280|BROADCAST|rdkafka#producer-1| [thrd:main]: Broadcasting state change
%7|1565626774.277|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565626774.277|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565626774.277|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565626774.277|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 3)
%7|1565626774.277|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 3, rtt 0.46ms)
%7|1565626774.277|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565626774.277|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626774.277|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626774.277|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626774.277|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626774.277|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626774.277|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 3, remove 0)
%7|1565626774.277|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565626774.277|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626774.277|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565626774.277|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565626775.279|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565626775.279|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565626775.279|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565626775.279|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 4)
%7|1565626775.279|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 4, rtt 0.48ms)
%7|1565626775.279|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565626775.279|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626775.279|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626775.279|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626775.279|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626775.280|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626775.280|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 3, remove 0)
%7|1565626775.280|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565626775.280|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626775.280|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565626775.280|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565626776.279|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565626776.279|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565626776.279|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565626776.279|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 5)
%7|1565626776.280|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 5, rtt 0.46ms)
%7|1565626776.280|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565626776.280|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626776.280|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626776.280|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626776.280|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626776.280|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626776.280|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 3, remove 0)
%7|1565626776.280|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565626776.280|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626776.280|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565626776.280|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565626777.283|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565626777.283|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565626777.283|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565626777.284|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 6)
%7|1565626777.284|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 6, rtt 0.51ms)
%7|1565626777.284|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565626777.284|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626777.284|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626777.284|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626777.284|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626777.284|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626777.284|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 3, remove 0)
%7|1565626777.284|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565626777.284|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626777.284|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565626777.284|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565626778.286|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565626778.286|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565626778.286|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565626778.286|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 7)
%7|1565626778.286|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 7, rtt 0.50ms)
%7|1565626778.286|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565626778.286|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626778.286|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626778.286|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626778.286|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626778.286|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626778.286|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 3, remove 0)
%7|1565626778.286|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565626778.286|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626778.286|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565626778.286|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565626779.286|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565626779.286|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565626779.286|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565626779.286|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 8)
%7|1565626779.287|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 8, rtt 0.44ms)
%7|1565626779.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565626779.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626779.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626779.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626779.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626779.287|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626779.287|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 3, remove 0)
%7|1565626779.287|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565626779.287|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626779.287|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565626779.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565626780.286|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565626780.286|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565626780.286|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565626780.286|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 9)
%7|1565626780.287|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 9, rtt 0.48ms)
%7|1565626780.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565626780.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626780.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626780.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626780.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626780.287|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626780.287|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 3, remove 0)
%7|1565626780.287|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565626780.287|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626780.287|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565626780.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565626781.286|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565626781.286|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565626781.286|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565626781.287|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 10)
%7|1565626781.287|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 10, rtt 0.47ms)
%7|1565626781.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565626781.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626781.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626781.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626781.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626781.287|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626781.287|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 3, remove 0)
%7|1565626781.287|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565626781.287|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626781.287|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565626781.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565626782.286|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565626782.287|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565626782.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565626782.287|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 11)
%7|1565626782.287|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 11, rtt 0.47ms)
%7|1565626782.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565626782.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626782.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626782.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626782.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626782.287|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626782.287|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 3, remove 0)
%7|1565626782.287|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565626782.287|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626782.287|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565626782.287|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565626783.290|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565626783.290|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565626783.290|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565626783.290|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 12)
%7|1565626783.290|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 12, rtt 0.42ms)
%7|1565626783.290|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565626783.290|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626783.290|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626783.290|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626783.290|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626783.290|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626783.290|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 3, remove 0)
%7|1565626783.290|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565626783.290|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626783.290|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565626783.290|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565626784.293|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565626784.293|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565626784.293|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565626784.293|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 13)
%7|1565626784.293|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 13, rtt 0.46ms)
%7|1565626784.293|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565626784.293|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626784.294|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626784.294|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626784.294|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626784.294|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626784.294|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 3, remove 0)
%7|1565626784.294|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565626784.294|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626784.294|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565626784.294|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565626785.295|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565626785.296|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565626785.296|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565626785.296|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 14)
%7|1565626785.296|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 14, rtt 0.38ms)
%7|1565626785.296|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565626785.296|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626785.296|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626785.296|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626785.296|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626785.296|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626785.296|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 3, remove 0)
%7|1565626785.296|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565626785.296|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626785.296|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565626785.296|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565626786.297|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565626786.297|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565626786.297|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565626786.297|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 15)
%7|1565626786.298|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 15, rtt 0.53ms)
%7|1565626786.298|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565626786.298|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626786.298|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626786.298|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626786.298|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626786.298|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626786.298|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 3, remove 0)
%7|1565626786.298|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565626786.298|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626786.298|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565626786.298|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565626787.299|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565626787.299|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565626787.299|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565626787.299|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 16)
%7|1565626787.299|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 16, rtt 0.48ms)
%7|1565626787.299|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565626787.299|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626787.299|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626787.299|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626787.299|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626787.299|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626787.299|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 3, remove 0)
%7|1565626787.299|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565626787.299|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626787.299|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565626787.299|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565626788.299|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565626788.299|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565626788.299|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565626788.299|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 17)
%7|1565626788.300|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 17, rtt 0.48ms)
%7|1565626788.300|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565626788.300|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626788.300|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626788.300|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626788.300|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626788.300|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626788.300|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 3, remove 0)
%7|1565626788.300|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565626788.300|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626788.300|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565626788.300|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565626789.301|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565626789.301|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565626789.301|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565626789.301|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 18)
%7|1565626789.302|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 18, rtt 0.47ms)
%7|1565626789.302|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565626789.302|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626789.302|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626789.302|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626789.302|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626789.302|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626789.302|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 3, remove 0)
%7|1565626789.302|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565626789.302|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626789.302|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565626789.302|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565626790.304|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565626790.304|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565626790.304|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565626790.304|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 19)
%7|1565626790.305|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 19, rtt 0.43ms)
%7|1565626790.305|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565626790.305|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626790.305|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626790.305|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626790.305|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626790.305|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626790.305|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 3, remove 0)
%7|1565626790.305|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565626790.305|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626790.305|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565626790.305|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565626791.306|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565626791.306|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565626791.306|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565626791.306|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 20)
%7|1565626791.307|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 20, rtt 0.46ms)
%7|1565626791.307|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565626791.307|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626791.307|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626791.307|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626791.307|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626791.307|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626791.307|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 3, remove 0)
%7|1565626791.307|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565626791.307|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626791.307|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565626791.307|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata
%7|1565626792.309|QRYLEADER|rdkafka#producer-1| [thrd:main]: Topic my-replicated-topic [0]: leader is internal: re-query
%7|1565626792.309|METADATA|rdkafka#producer-1| [thrd:main]: Requesting metadata for 1/1 topics: refresh unavailable topics
%7|1565626792.309|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: Request metadata for 1 topic(s): refresh unavailable topics
%7|1565626792.309|SEND|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Sent MetadataRequest (v2, 46 bytes @ 0, CorrId 21)
%7|1565626792.310|RECV|rdkafka#producer-1| [thrd:localhost:9094/bootstrap]: localhost:9094/bootstrap: Received MetadataResponse (v2, 114 bytes, CorrId 21, rtt 0.55ms)
%7|1565626792.310|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ===== Received metadata (for 1 requested topics): refresh unavailable topics =====
%7|1565626792.310|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: ClusterId: Grf0KqAdRGKnqq_GmNI6yw, ControllerId: 2
%7|1565626792.310|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1 brokers, 1 topics
%7|1565626792.310|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Broker #0/1: 172.16.22.33:9094 NodeId 2
%7|1565626792.310|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap:   Topic #0/1: my-replicated-topic with 1 partitions
%7|1565626792.310|METADATA|rdkafka#producer-1| [thrd:main]:   Topic my-replicated-topic partition 0 Leader -1
%7|1565626792.310|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: delegate to broker (none) (rktp 0x7fb6add0fdf0, term 0, ref 3, remove 0)
%7|1565626792.310|BRKDELGT|rdkafka#producer-1| [thrd:main]: my-replicated-topic [0]: not updating broker: already on correct broker :0/internal
%7|1565626792.310|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic my-replicated-topic to 1 partitions
%7|1565626792.310|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic my-replicated-topic
%7|1565626792.310|METADATA|rdkafka#producer-1| [thrd:main]: localhost:9094/bootstrap: 1/1 requested topic(s) seen in metadata

server-1.properties

# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements.  See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License.  You may obtain a copy of the License at
#
#    http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

# see kafka.server.KafkaConfig for additional details and defaults

############################# Server Basics #############################

# The id of the broker. This must be set to a unique integer for each broker.
broker.id=1

############################# Socket Server Settings #############################

# The address the socket server listens on. It will get the value returned from 
# java.net.InetAddress.getCanonicalHostName() if not configured.
#   FORMAT:
#     listeners = listener_name://host_name:port
#   EXAMPLE:
#     listeners = PLAINTEXT://your.host.name:9092
listeners=PLAINTEXT://:9093

# Hostname and port the broker will advertise to producers and consumers. If not set, 
# it uses the value for "listeners" if configured.  Otherwise, it will use the value
# returned from java.net.InetAddress.getCanonicalHostName().
#advertised.listeners=PLAINTEXT://your.host.name:9092

# Maps listener names to security protocols, the default is for them to be the same. See the config documentation for more details
#listener.security.protocol.map=PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL

# The number of threads that the server uses for receiving requests from the network and sending responses to the network
num.network.threads=3

# The number of threads that the server uses for processing requests, which may include disk I/O
num.io.threads=8

# The send buffer (SO_SNDBUF) used by the socket server
socket.send.buffer.bytes=102400

# The receive buffer (SO_RCVBUF) used by the socket server
socket.receive.buffer.bytes=102400

# The maximum size of a request that the socket server will accept (protection against OOM)
socket.request.max.bytes=104857600


############################# Log Basics #############################

# A comma separated list of directories under which to store log files
log.dirs=/tmp/kafka-logs-1

# The default number of log partitions per topic. More partitions allow greater
# parallelism for consumption, but this will also result in more files across
# the brokers.
num.partitions=1

# The number of threads per data directory to be used for log recovery at startup and flushing at shutdown.
# This value is recommended to be increased for installations with data dirs located in RAID array.
num.recovery.threads.per.data.dir=1

############################# Internal Topic Settings  #############################
# The replication factor for the group metadata internal topics "__consumer_offsets" and "__transaction_state"
# For anything other than development testing, a value greater than 1 is recommended for to ensure availability such as 3.
offsets.topic.replication.factor=1
transaction.state.log.replication.factor=1
transaction.state.log.min.isr=1

############################# Log Flush Policy #############################

# Messages are immediately written to the filesystem but by default we only fsync() to sync
# the OS cache lazily. The following configurations control the flush of data to disk.
# There are a few important trade-offs here:
#    1. Durability: Unflushed data may be lost if you are not using replication.
#    2. Latency: Very large flush intervals may lead to latency spikes when the flush does occur as there will be a lot of data to flush.
#    3. Throughput: The flush is generally the most expensive operation, and a small flush interval may lead to excessive seeks.
# The settings below allow one to configure the flush policy to flush data after a period of time or
# every N messages (or both). This can be done globally and overridden on a per-topic basis.

# The number of messages to accept before forcing a flush of data to disk
#log.flush.interval.messages=10000

# The maximum amount of time a message can sit in a log before we force a flush
#log.flush.interval.ms=1000

############################# Log Retention Policy #############################

# The following configurations control the disposal of log segments. The policy can
# be set to delete segments after a period of time, or after a given size has accumulated.
# A segment will be deleted whenever *either* of these criteria are met. Deletion always happens
# from the end of the log.

# The minimum age of a log file to be eligible for deletion due to age
log.retention.hours=168

# A size-based retention policy for logs. Segments are pruned from the log unless the remaining
# segments drop below log.retention.bytes. Functions independently of log.retention.hours.
#log.retention.bytes=1073741824

# The maximum size of a log segment file. When this size is reached a new log segment will be created.
log.segment.bytes=1073741824

# The interval at which log segments are checked to see if they can be deleted according
# to the retention policies
log.retention.check.interval.ms=300000

############################# Zookeeper #############################

# Zookeeper connection string (see zookeeper docs for details).
# This is a comma separated host:port pairs, each corresponding to a zk
# server. e.g. "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002".
# You can also append an optional chroot string to the urls to specify the
# root directory for all kafka znodes.
zookeeper.connect=localhost:2181

# Timeout in ms for connecting to zookeeper
zookeeper.connection.timeout.ms=6000


############################# Group Coordinator Settings #############################

# The following configuration specifies the time, in milliseconds, that the GroupCoordinator will delay the initial consumer rebalance.
# The rebalance will be further delayed by the value of group.initial.rebalance.delay.ms as new members join the group, up to a maximum of max.poll.interval.ms.
# The default value for this is 3 seconds.
# We override this to 0 here as it makes for a better out-of-the-box experience for development and testing.
# However, in production environments the default value of 3 seconds is more suitable as this will help to avoid unnecessary, and potentially expensive, rebalances during application startup.
group.initial.rebalance.delay.ms=0

server-2.properties

# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements.  See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License.  You may obtain a copy of the License at
#
#    http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

# see kafka.server.KafkaConfig for additional details and defaults

############################# Server Basics #############################

# The id of the broker. This must be set to a unique integer for each broker.
broker.id=2

############################# Socket Server Settings #############################

# The address the socket server listens on. It will get the value returned from 
# java.net.InetAddress.getCanonicalHostName() if not configured.
#   FORMAT:
#     listeners = listener_name://host_name:port
#   EXAMPLE:
#     listeners = PLAINTEXT://your.host.name:9092
listeners=PLAINTEXT://:9094

# Hostname and port the broker will advertise to producers and consumers. If not set, 
# it uses the value for "listeners" if configured.  Otherwise, it will use the value
# returned from java.net.InetAddress.getCanonicalHostName().
#advertised.listeners=PLAINTEXT://your.host.name:9092

# Maps listener names to security protocols, the default is for them to be the same. See the config documentation for more details
#listener.security.protocol.map=PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL

# The number of threads that the server uses for receiving requests from the network and sending responses to the network
num.network.threads=3

# The number of threads that the server uses for processing requests, which may include disk I/O
num.io.threads=8

# The send buffer (SO_SNDBUF) used by the socket server
socket.send.buffer.bytes=102400

# The receive buffer (SO_RCVBUF) used by the socket server
socket.receive.buffer.bytes=102400

# The maximum size of a request that the socket server will accept (protection against OOM)
socket.request.max.bytes=104857600


############################# Log Basics #############################

# A comma separated list of directories under which to store log files
log.dirs=/tmp/kafka-logs-2

# The default number of log partitions per topic. More partitions allow greater
# parallelism for consumption, but this will also result in more files across
# the brokers.
num.partitions=1

# The number of threads per data directory to be used for log recovery at startup and flushing at shutdown.
# This value is recommended to be increased for installations with data dirs located in RAID array.
num.recovery.threads.per.data.dir=1

############################# Internal Topic Settings  #############################
# The replication factor for the group metadata internal topics "__consumer_offsets" and "__transaction_state"
# For anything other than development testing, a value greater than 1 is recommended for to ensure availability such as 3.
offsets.topic.replication.factor=1
transaction.state.log.replication.factor=1
transaction.state.log.min.isr=1

############################# Log Flush Policy #############################

# Messages are immediately written to the filesystem but by default we only fsync() to sync
# the OS cache lazily. The following configurations control the flush of data to disk.
# There are a few important trade-offs here:
#    1. Durability: Unflushed data may be lost if you are not using replication.
#    2. Latency: Very large flush intervals may lead to latency spikes when the flush does occur as there will be a lot of data to flush.
#    3. Throughput: The flush is generally the most expensive operation, and a small flush interval may lead to excessive seeks.
# The settings below allow one to configure the flush policy to flush data after a period of time or
# every N messages (or both). This can be done globally and overridden on a per-topic basis.

# The number of messages to accept before forcing a flush of data to disk
#log.flush.interval.messages=10000

# The maximum amount of time a message can sit in a log before we force a flush
#log.flush.interval.ms=1000

############################# Log Retention Policy #############################

# The following configurations control the disposal of log segments. The policy can
# be set to delete segments after a period of time, or after a given size has accumulated.
# A segment will be deleted whenever *either* of these criteria are met. Deletion always happens
# from the end of the log.

# The minimum age of a log file to be eligible for deletion due to age
log.retention.hours=168

# A size-based retention policy for logs. Segments are pruned from the log unless the remaining
# segments drop below log.retention.bytes. Functions independently of log.retention.hours.
#log.retention.bytes=1073741824

# The maximum size of a log segment file. When this size is reached a new log segment will be created.
log.segment.bytes=1073741824

# The interval at which log segments are checked to see if they can be deleted according
# to the retention policies
log.retention.check.interval.ms=300000

############################# Zookeeper #############################

# Zookeeper connection string (see zookeeper docs for details).
# This is a comma separated host:port pairs, each corresponding to a zk
# server. e.g. "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002".
# You can also append an optional chroot string to the urls to specify the
# root directory for all kafka znodes.
zookeeper.connect=localhost:2181

# Timeout in ms for connecting to zookeeper
zookeeper.connection.timeout.ms=6000


############################# Group Coordinator Settings #############################

# The following configuration specifies the time, in milliseconds, that the GroupCoordinator will delay the initial consumer rebalance.
# The rebalance will be further delayed by the value of group.initial.rebalance.delay.ms as new members join the group, up to a maximum of max.poll.interval.ms.
# The default value for this is 3 seconds.
# We override this to 0 here as it makes for a better out-of-the-box experience for development and testing.
# However, in production environments the default value of 3 seconds is more suitable as this will help to avoid unnecessary, and potentially expensive, rebalances during application startup.
group.initial.rebalance.delay.ms=0

server.properties

# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements.  See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License.  You may obtain a copy of the License at
#
#    http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

# see kafka.server.KafkaConfig for additional details and defaults

############################# Server Basics #############################

# The id of the broker. This must be set to a unique integer for each broker.
broker.id=0

############################# Socket Server Settings #############################

# The address the socket server listens on. It will get the value returned from 
# java.net.InetAddress.getCanonicalHostName() if not configured.
#   FORMAT:
#     listeners = listener_name://host_name:port
#   EXAMPLE:
#     listeners = PLAINTEXT://your.host.name:9092
#listeners=PLAINTEXT://:9092

# Hostname and port the broker will advertise to producers and consumers. If not set, 
# it uses the value for "listeners" if configured.  Otherwise, it will use the value
# returned from java.net.InetAddress.getCanonicalHostName().
#advertised.listeners=PLAINTEXT://your.host.name:9092

# Maps listener names to security protocols, the default is for them to be the same. See the config documentation for more details
#listener.security.protocol.map=PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL

# The number of threads that the server uses for receiving requests from the network and sending responses to the network
num.network.threads=3

# The number of threads that the server uses for processing requests, which may include disk I/O
num.io.threads=8

# The send buffer (SO_SNDBUF) used by the socket server
socket.send.buffer.bytes=102400

# The receive buffer (SO_RCVBUF) used by the socket server
socket.receive.buffer.bytes=102400

# The maximum size of a request that the socket server will accept (protection against OOM)
socket.request.max.bytes=104857600


############################# Log Basics #############################

# A comma separated list of directories under which to store log files
log.dirs=/tmp/kafka-logs

# The default number of log partitions per topic. More partitions allow greater
# parallelism for consumption, but this will also result in more files across
# the brokers.
num.partitions=1

# The number of threads per data directory to be used for log recovery at startup and flushing at shutdown.
# This value is recommended to be increased for installations with data dirs located in RAID array.
num.recovery.threads.per.data.dir=1

############################# Internal Topic Settings  #############################
# The replication factor for the group metadata internal topics "__consumer_offsets" and "__transaction_state"
# For anything other than development testing, a value greater than 1 is recommended for to ensure availability such as 3.
offsets.topic.replication.factor=1
transaction.state.log.replication.factor=1
transaction.state.log.min.isr=1

############################# Log Flush Policy #############################

# Messages are immediately written to the filesystem but by default we only fsync() to sync
# the OS cache lazily. The following configurations control the flush of data to disk.
# There are a few important trade-offs here:
#    1. Durability: Unflushed data may be lost if you are not using replication.
#    2. Latency: Very large flush intervals may lead to latency spikes when the flush does occur as there will be a lot of data to flush.
#    3. Throughput: The flush is generally the most expensive operation, and a small flush interval may lead to excessive seeks.
# The settings below allow one to configure the flush policy to flush data after a period of time or
# every N messages (or both). This can be done globally and overridden on a per-topic basis.

# The number of messages to accept before forcing a flush of data to disk
#log.flush.interval.messages=10000

# The maximum amount of time a message can sit in a log before we force a flush
#log.flush.interval.ms=1000

############################# Log Retention Policy #############################

# The following configurations control the disposal of log segments. The policy can
# be set to delete segments after a period of time, or after a given size has accumulated.
# A segment will be deleted whenever *either* of these criteria are met. Deletion always happens
# from the end of the log.

# The minimum age of a log file to be eligible for deletion due to age
log.retention.hours=168

# A size-based retention policy for logs. Segments are pruned from the log unless the remaining
# segments drop below log.retention.bytes. Functions independently of log.retention.hours.
#log.retention.bytes=1073741824

# The maximum size of a log segment file. When this size is reached a new log segment will be created.
log.segment.bytes=1073741824

# The interval at which log segments are checked to see if they can be deleted according
# to the retention policies
log.retention.check.interval.ms=300000

############################# Zookeeper #############################

# Zookeeper connection string (see zookeeper docs for details).
# This is a comma separated host:port pairs, each corresponding to a zk
# server. e.g. "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002".
# You can also append an optional chroot string to the urls to specify the
# root directory for all kafka znodes.
zookeeper.connect=localhost:2181

# Timeout in ms for connecting to zookeeper
zookeeper.connection.timeout.ms=6000


############################# Group Coordinator Settings #############################

# The following configuration specifies the time, in milliseconds, that the GroupCoordinator will delay the initial consumer rebalance.
# The rebalance will be further delayed by the value of group.initial.rebalance.delay.ms as new members join the group, up to a maximum of max.poll.interval.ms.
# The default value for this is 3 seconds.
# We override this to 0 here as it makes for a better out-of-the-box experience for development and testing.
# However, in production environments the default value of 3 seconds is more suitable as this will help to avoid unnecessary, and potentially expensive, rebalances during application startup.
group.initial.rebalance.delay.ms=0