Last active
October 21, 2019 19:59
-
-
Save blachniet/2f091c5e2f7c21ba590b0f7e533768dd to your computer and use it in GitHub Desktop.
The Confluent.Kafka C# producer hangs indefinitely when the target partition has no leader. See https://github.com/confluentinc/confluent-kafka-dotnet/issues/1027
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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!"); | |
| } | |
| } | |
| } | |
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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() |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| %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 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| %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 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| # 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 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| # 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 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| # 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 |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment