Kafka Message loss when Kafkaserver goes down #4099

ksdvishnukumar · 2022-12-08T08:19:11Z

ksdvishnukumar
Dec 8, 2022

I have a scenario that when Kafka server or Zookeeper both goes down, but the producer application trying to send a message to Kafka broker.

When the Kafka broker or Zookeeper comes online, messages is getting lost.

Below are my configuration to reproduce

new ProducerConfig
{
    BootstrapServers = <BROKET_END_POINT>,
    MessageMaxBytes = 20971520,
    MessageCopyMaxBytes = 20971520,
    LogConnectionClose = false,    
    BrokerAddressFamily = BrokerAddressFamily.V4,
    ConnectionsMaxIdleMs = 0,
    //https://github.com/Azure/azure-event-hubs-for-kafka/issues/139
    SocketKeepaliveEnable = true,
    MetadataMaxAgeMs = 180000,
    //https://learn.microsoft.com/en-us/azure/event-hubs/apache-kafka-configurations
    RequestTimeoutMs = 60000,
    MessageTimeoutMs = 0,
    MessageSendMaxRetries = int.MaxValue,
    RetryBackoffMs = 100,
    EnableIdempotence = true,
    Acks = Acks.All,
    BatchSize = 2000000,
    LingerMs = 0,
    CompressionType = CompressionType.Gzip
    SocketNagleDisable = true
};

I have a scenario that when Kafka server or Zookeeper both goes down, but the producer application trying to send a message to Kafka broker.

When the Kafka broker or Zookeeper comes online, messages is getting lost and i see the producer delivery result offset has Offset: -1001 and Partition [Any]

I used the above mentioned setting to produce the message using Confluent kafka nuget package version 1.8.2 from .Net code.

Appreciate your inputs in advance @edenhill

edenhill · 2022-12-08T09:38:54Z

edenhill
Dec 8, 2022

Is there an error associated with that delivery result? There should be

6 replies

edenhill Dec 8, 2022

Then the message is not lost, it failed to deliver because the topic or partition doesn't/no-longer exists - if this happens when a broker goes down it is typically because the topic is not properly replicated. Use a replication factor of 3.

ksdvishnukumar Dec 8, 2022
Author

Thanks for quick reply @edenhill. I agree with you on replication factor to be 3, But for some reason we are using single kafka server and Zookeeper. How do we overcome with this message loss.

I understand that by having MessageTimeoutMs to 0 (infinite message expiry), retry to be max integer, and retrybackoffms 100ms internally message is retrying to delivery to kafka topic. With this setting, ideally message should not expire, when server comes online (Topic and Partitions are available) message should be delivered.

Not sure for what reason message is not able to deliver. Is there any setting is available for delivery timeout.
Earlier used to have delivery.timeout.ms. but its deprecated in the current version.

kindly give a thought on this.

Below is the another message on the same scenario, sometimes Exception message says Local: Unknown partition sometime Broker: Unknown topic or partition

And also I observed that Kafka server is up after 1 minute then the message is lost. if kafka is up before 1 min. then message is able to produce it.

ksdvishnukumarcse Dec 9, 2022

@edenhill Appreciate your inputs to understand the above behaviour further

ksdvishnukumar Dec 9, 2022
Author

@edenhill and @mhowlett
Below are the formatted logs taken from broker,protocol,topic,msg debug logs + Application logs as well.
The logs generated in the below sequence.
Application started after couple of minutes Broker down, waited for more than a minutes then broker up

`
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.7900859Z|BROKER|rdkafka#producer-1|[[thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.7900999Z|BRKMAIN|rdkafka#producer-1|[[thrd::0/internal]: :0/internal: Enter main broker thread]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.7983806Z|CONNECT|rdkafka#producer-1|[[thrd:app]: localhost:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.7985419Z|BRKMAIN|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.7985861Z|INIT|rdkafka#producer-1|[[thrd:app]: librdkafka v1.8.2 (0x10802ff) rdkafka#producer-1 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, SSL ZLIB SNAPPY SASL_SCRAM PLUGINS HDRHISTOGRAM, debug 0xc6)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.7986920Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
warn: My.Logger[0]
Producer Log Handler : WARNING|09-12-2022T17:35:56.7987466Z|CONFWARN|rdkafka#producer-1|[[thrd:app]: Configuration property allow.auto.create.topics is a consumer property and will be ignored by this producer instance]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.7988256Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.7988790Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.7989110Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.8048380Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 1576]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.8054067Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected to ipv4#127.0.0.1:9092]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.8055072Z|CONNECTED|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected (#1)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.8055728Z|FEATURE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.8056145Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.8057527Z|SEND|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent ApiVersionRequest (v3, 52 bytes @ 0, CorrId 1)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.8073381Z|RECV|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received ApiVersionResponse (v3, 431 bytes, CorrId 1, rtt 1.53ms)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.8075142Z|FEATURE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.8075825Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.8078221Z|SEND|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent MetadataRequest (v4, 26 bytes @ 0, CorrId 2)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.8084328Z|RECV|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received MetadataResponse (v4, 72 bytes, CorrId 2, rtt 0.61ms)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.8091167Z|BROKER|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Added new broker with NodeId 0]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.8092080Z|CLUSTERID|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: ClusterId update "" -> "Qq-HolD8Q-ytsteNY2YIRw"]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.8092482Z|CONTROLLERID|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: ControllerId update -1 -> 0]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:35:56.8093584Z|BRKMAIN|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Enter main broker thread]
info: My.Logger[0]
my-consumer-topic partitions incrementally assigned: [0], all: [0] at 09-12-2022T17:35:56.8473514Z
info: My.Logger[0]
Message Offset 10086 consumed.
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:02.2381804Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Disconnected (after 5430ms in state UP) (_TRANSPORT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:02.2388904Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state UP -> DOWN]
info: My.Logger[0]
Consumer Log Handler : INFO|09-12-2022T17:36:02.2388891Z|FAIL|rdkafka#consumer-2|[[thrd:GroupCoordinator]: GroupCoordinator: host.docker.internal:9092: Disconnected (after 5413ms in state UP)]
info: My.Logger[0]
Consumer Log Handler : INFO|09-12-2022T17:36:02.2388904Z|FAIL|rdkafka#consumer-2|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Disconnected (after 5380ms in state UP)]
info: My.Logger[0]
Consumer Log Handler : INFO|09-12-2022T17:36:02.2388963Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Disconnected (after 5418ms in state UP)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:02.2390649Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:02.2392548Z|ERROR|rdkafka#consumer-2|[[thrd:host.docker.internal:9092/0]: 3/3 brokers are down]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:02.8396926Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: no cluster connection (broker has 0 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:02.8400830Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:02.8402396Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:02.8402787Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:02.8402922Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:02.8406243Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 2016]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:03.8545332Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 1 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:03.8557017Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:03.8558996Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:03.8559942Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:03.8560663Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:03.8567066Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 1996]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:04.2791611Z|FAIL|rdkafka#consumer-2|[[thrd:GroupCoordinator]: GroupCoordinator: host.docker.internal:9092: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2039ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:04.2952290Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2055ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:04.3114704Z|FAIL|rdkafka#consumer-2|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2071ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:04.8619007Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:04.8777289Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2037ms in state CONNECT) (_TRANSPORT)]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:04.8790805Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2037ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:04.8801325Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:04.8802861Z|ERROR|rdkafka#producer-1|[[thrd:app]: rdkafka#producer-1: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2037ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:04.8803247Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:05.8757219Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: no cluster connection (broker has 1 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:05.8766564Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:05.8772230Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:05.8774773Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:05.8775804Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:05.8787265Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 1576]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:05.9074604Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2051ms in state CONNECT) (_TRANSPORT)]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:05.9080312Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2051ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:05.9083005Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:05.9083387Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:05.9083777Z|ERROR|rdkafka#producer-1|[[thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2051ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:06.3466281Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2034ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:06.6425355Z|FAIL|rdkafka#consumer-2|[[thrd:GroupCoordinator]: GroupCoordinator: host.docker.internal:9092: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2061ms in state CONNECT, 1 identical error(s) suppressed)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:06.6585548Z|FAIL|rdkafka#consumer-2|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2031ms in state CONNECT, 1 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:06.8774794Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: no cluster connection (broker has 2 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:06.8779995Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:06.8781011Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:06.8781380Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:06.8781863Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:06.8787757Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2020]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:06.9370611Z|TOPIC|rdkafka#producer-1|[[thrd:app]: New local topic: my-producer-topic]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:06.9375566Z|TOPPARNEW|rdkafka#producer-1|[[thrd:app]: NEW my-producer-topic [-1] 000001E2B91662F0 refcnt 000001E2B9166380 (at rd_kafka_topic_new0:465)]
dbug: My.Logger[0]
No messages found from my-consumer-topic - 0 @ 09-12-2022T17:36:06.9389017Z
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:06.9389652Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: GroupCoordinator: host.docker.internal:9092: Disconnected (after 5413ms in state UP)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:06.9391734Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Disconnected (after 5418ms in state UP)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:06.9392703Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: host.docker.internal:9092/0: Disconnected (after 5380ms in state UP)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:06.9393382Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: GroupCoordinator: host.docker.internal:9092: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2039ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:06.9394013Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2055ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:06.9394632Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2071ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:06.9395198Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2034ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:06.9395805Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: GroupCoordinator: host.docker.internal:9092: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2061ms in state CONNECT, 1 identical error(s) suppressed)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:06.9396388Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2031ms in state CONNECT, 1 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:07.8801533Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:07.8805261Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:07.8806898Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:07.8808162Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:07.9117181Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: No connection could be made because the target machine actively refused it... (after 2033ms in state CONNECT) (_TRANSPORT)]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:07.9121817Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: No connection could be made because the target machine actively refused it... (after 2033ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:07.9133298Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:07.9134041Z|ERROR|rdkafka#producer-1|[[thrd:app]: rdkafka#producer-1: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: No connection could be made because the target machine actively refused it... (after 2033ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:07.9135095Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:08.5182301Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2062ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:08.5205499Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2062ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:08.8908394Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:08.8912270Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:08.8913825Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 2 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:08.8917808Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:08.8918633Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:08.8921898Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:08.8923475Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:08.8924156Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:08.8937140Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 2040]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:08.9221657Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2043ms in state CONNECT, 1 identical error(s) suppressed) (_TRANSPORT): identical to last error]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:08.9224767Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2043ms in state CONNECT, 1 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:08.9232932Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:08.9233689Z|ERROR|rdkafka#producer-1|[[thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2043ms in state CONNECT, 1 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:08.9234301Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:09.9049020Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:09.9062988Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:09.9065913Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 3 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:09.9069666Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:09.9070511Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:09.9072453Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:09.9073399Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:09.9074057Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:09.9085009Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2020]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:10.9160770Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:10.9174355Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:10.9178702Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:10.9181199Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:10.9483431Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2055ms in state CONNECT) (_TRANSPORT)]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:10.9486929Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2055ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:10.9495551Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:10.9496445Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:10.9496742Z|ERROR|rdkafka#producer-1|[[thrd:app]: rdkafka#producer-1: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2055ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:10.9791153Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2056ms in state CONNECT, 1 identical error(s) suppressed)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:10.9804068Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2056ms in state CONNECT, 1 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:11.9296430Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:11.9301704Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:11.9302620Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 3 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:11.9304981Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:11.9305862Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:11.9307635Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:11.9308440Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:11.9309154Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:11.9317235Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 1960]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:11.9762948Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2068ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:11.9764119Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:11.9764454Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:12.9393961Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:12.9397076Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:12.9397777Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 4 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:12.9400137Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:12.9401546Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:12.9403595Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:12.9404578Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:12.9405305Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:12.9416418Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 1992]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:13.0643300Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2053ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:13.0656501Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2053ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:13.9537344Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:13.9539668Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:13.9540502Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:13.9541331Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:13.9848081Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2053ms in state CONNECT, 1 identical error(s) suppressed) (_TRANSPORT): identical to last error]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:13.9850785Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2053ms in state CONNECT, 1 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:13.9864835Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:13.9865539Z|ERROR|rdkafka#producer-1|[[thrd:app]: rdkafka#producer-1: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2053ms in state CONNECT, 1 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:13.9866213Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:14.9542104Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:14.9548161Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:14.9550957Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 4 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:14.9554191Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:14.9554606Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:14.9557326Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:14.9558063Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:14.9558509Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:14.9569792Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 2032]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:14.9843144Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2043ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:14.9845182Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:14.9845687Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:15.6081870Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2058ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:15.6085761Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2058ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:15.9665055Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:15.9675371Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:15.9676434Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 5 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:15.9678448Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:15.9679230Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:15.9680787Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:15.9681483Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:15.9682025Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:15.9690436Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2040]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:16.9805268Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:16.9819117Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:16.9822181Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:16.9826861Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:17.0268598Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2070ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:17.0270952Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:17.0271811Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:17.9966866Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:17.9969886Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:17.9970170Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 5 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:17.9971340Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:17.9971701Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:17.9972254Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:17.9972544Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:17.9972753Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:17.9978083Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 604]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:18.0266275Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2058ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:18.0267503Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:18.0267864Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:18.0429356Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2044ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:18.0432595Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2044ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:19.0042712Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:19.0060289Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:19.0070663Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 6 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:19.0074322Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:19.0075071Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:19.0077346Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:19.0078338Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:19.0079012Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:19.0089972Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 1920]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:20.0192404Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:20.0196092Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:20.0197451Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:20.0198707Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:20.0355486Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2038ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:20.0365490Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:20.0366915Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:20.1595931Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2052ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:20.1610012Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2052ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:21.0284849Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:21.0288283Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:21.0289055Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 6 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:21.0291251Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:21.0292177Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:21.0294524Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:21.0295362Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:21.0295965Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:21.0307820Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 608]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:21.0446150Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2036ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:21.0461209Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:21.0464545Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:22.0376738Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:22.0381380Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:22.0382720Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 7 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:22.0387014Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:22.0387387Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:22.0392224Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:22.0394095Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:22.0394847Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:22.0406354Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 1920]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:22.7070260Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2054ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:22.7091880Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2054ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:23.0509326Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:23.0513596Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:23.0515508Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:23.0516790Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:23.0971826Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2067ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:23.0974419Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:23.0975539Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:24.0657899Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:24.0669762Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:24.0672909Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 7 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:24.0678289Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:24.0679254Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:24.0681107Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:24.0681644Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:24.0682183Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:24.0691645Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 2024]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:24.0975398Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2057ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:24.0978697Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:24.0980322Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:25.0796638Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:25.0805217Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:25.0806622Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 8 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:25.0810224Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:25.0810689Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:25.0814331Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:25.0815297Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:25.0816226Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:25.0827084Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 1576]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:26.0824940Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:26.0846889Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:26.0849066Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:26.0850147Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:26.1288807Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2060ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:26.1290360Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:26.1291664Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:27.0975578Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:27.0977772Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:27.0978723Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 8 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:27.0981537Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:27.0981865Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:27.0984302Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:27.0996323Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:27.0997961Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:27.1007596Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 1160]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:27.1297704Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2048ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:27.1300120Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:27.1301770Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:27.2546308Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2032ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:27.2553427Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2032ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:28.0983814Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:28.0987365Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:28.0988680Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 9 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:28.0992855Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:28.0993796Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:28.0996638Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:28.0997719Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:28.0999160Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:28.1009889Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 1920]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:29.1119262Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:29.1141956Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:29.1144417Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:29.1145856Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:29.1739420Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2074ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:29.1743694Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:29.1745532Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
warn: My.Logger[0]
Consumer Log Handler : WARNING|09-12-2022T17:36:30.1106923Z|SESSTMOUT|rdkafka#consumer-2|[[thrd:main]: Consumer group session timed out (in join-state steady) after 30260 ms without a successful response from the group coordinator (broker 0, last error was Success): revoking assignment and rejoining group]
info: My.Logger[0]
my-consumer-topic partitions were lost from topic: [my-consumer-topic [[0]] @10087] at 09-12-2022T17:36:30.1172029Z
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:30.1262960Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:30.1267133Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:30.1268477Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 9 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:30.1272576Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:30.1273528Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:30.1276301Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:30.1277704Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:30.1278537Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:30.1289466Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 2068]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:30.1726033Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2072ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:30.1729703Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:30.1731648Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:31.1379188Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:31.1395345Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:31.1397378Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 10 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:31.1400397Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:31.1401049Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:31.1402613Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:31.1403430Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:31.1404233Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:31.1413288Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2076]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:32.1528045Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:32.1535272Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:32.1536550Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:32.1537358Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:32.1850500Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2057ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:32.1854441Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:32.1855779Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:33.1538621Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:33.1542905Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:33.1544241Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 10 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:33.1548128Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:33.1549574Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:33.1552991Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:33.1554474Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:33.1555152Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:33.1565967Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 2068]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:33.1694246Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2028ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:33.1713118Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:33.1714741Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:34.1680285Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:34.1686369Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:34.1688640Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 11 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:34.1692932Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:34.1693866Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:34.1696723Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:34.1698208Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:34.1699004Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:34.1709766Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2076]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:34.3707527Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2060ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:34.3732235Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2060ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:35.1703078Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:35.1706548Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:35.1708270Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:35.1709280Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:35.2173347Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2061ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:35.2176729Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:35.2178487Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:36.1719342Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:36.1741928Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:36.1743999Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 11 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:36.1747230Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:36.1747771Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:36.1749722Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:36.1750702Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:36.1751343Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:36.1762444Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 2052]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:36.2032746Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2033ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:36.2036237Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:36.2037326Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:36.8603605Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: No connection could be made because the target machine actively refused it... (after 2020ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:36.8614135Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: No connection could be made because the target machine actively refused it... (after 2020ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:37.1870395Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:37.1891999Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:37.1893767Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 12 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:37.1896736Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:37.1897454Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:37.1899176Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:37.1900403Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:37.1901031Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:37.1911827Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2080]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:38.2002848Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:38.2024281Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:38.2026423Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:38.2027415Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:38.2315938Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2056ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:38.2317257Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:38.2317709Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:39.2117516Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:39.2126089Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:39.2128220Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 12 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:39.2131972Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:39.2132681Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:39.2134741Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:39.2135614Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:39.2136269Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:39.2147227Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 2052]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:39.2274302Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2072ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:39.2286178Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2072ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:39.2588834Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2068ms in state CONNECT, 10 identical error(s) suppressed) (_TRANSPORT): identical to last error]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:39.2592706Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2068ms in state CONNECT, 10 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:39.2602760Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:39.2603620Z|ERROR|rdkafka#producer-1|[[thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2068ms in state CONNECT, 10 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:39.2605416Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:40.2134028Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:40.2137608Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:40.2139232Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 13 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:40.2143015Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:40.2144154Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:40.2147283Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:40.2148341Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:40.2149409Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:40.2162633Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2020]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:40.3046697Z|FAIL|rdkafka#consumer-2|[[thrd:GroupCoordinator]: GroupCoordinator: host.docker.internal:9092: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2057ms in state CONNECT, 4 identical error(s) suppressed)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:40.3073425Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: GroupCoordinator: host.docker.internal:9092: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2057ms in state CONNECT, 4 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:41.2278055Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:41.2281422Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:41.2282996Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:41.2283965Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:41.2756653Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2061ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:41.2759977Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:41.2761249Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:41.4447307Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2029ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:41.4467206Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2029ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:42.2412201Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:42.2416012Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:42.2417605Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 13 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:42.2421426Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:42.2422832Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:42.2425568Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:42.2426794Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:42.2427574Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:42.2438150Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 2060]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:42.2732481Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2058ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:42.2735704Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:42.2737432Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:43.2457827Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:43.2466264Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:43.2467008Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 14 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:43.2468349Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:43.2468825Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:43.2469279Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:43.2469572Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:43.2469891Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:43.2474437Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2020]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:43.9265396Z|FAIL|rdkafka#consumer-2|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2059ms in state CONNECT, 4 identical error(s) suppressed)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:43.9271315Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2059ms in state CONNECT, 4 identical error(s) suppressed)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:44.0063850Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2060ms in state CONNECT, 1 identical error(s) suppressed)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:44.0069381Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2060ms in state CONNECT, 1 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:44.2468956Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:44.2470029Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:44.2470475Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:44.2470747Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:44.2941384Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2051ms in state CONNECT, 10 identical error(s) suppressed) (_TRANSPORT): identical to last error]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:44.2947530Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2051ms in state CONNECT, 10 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:44.2951653Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:44.2952137Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:44.2952138Z|ERROR|rdkafka#producer-1|[[thrd:app]: rdkafka#producer-1: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2051ms in state CONNECT, 10 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:45.2593274Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:45.2596609Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:45.2597730Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 14 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:45.2601209Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:45.2602234Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:45.2605223Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:45.2606390Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:45.2607149Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:45.2617898Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 2080]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:45.2757698Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: No connection could be made because the target machine actively refused it... (after 2028ms in state CONNECT) (_TRANSPORT)]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:45.2761494Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: No connection could be made because the target machine actively refused it... (after 2028ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:45.2770216Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:45.2771176Z|ERROR|rdkafka#producer-1|[[thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: No connection could be made because the target machine actively refused it... (after 2028ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:45.2771671Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:46.2637422Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:46.2663736Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:46.2666553Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 15 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:46.2670263Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:46.2670791Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:46.2672526Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:46.2673362Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:46.2673995Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:46.2683693Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2020]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:47.2788656Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:47.2798990Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:47.2800654Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:47.2802280Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:47.2951219Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2034ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:47.2954813Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:47.2956111Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:48.2795861Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: No connection could be made because the target machine actively refused it... (after 2012ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:48.2800588Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:48.2802722Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:48.2947213Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:48.2965711Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:48.2967440Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 15 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:48.2970685Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:48.2971165Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:48.2973151Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:48.2973925Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:48.2974473Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:48.2983293Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 2076]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:48.5592937Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2046ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:48.5604723Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2046ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:49.3107465Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:49.3128474Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:49.3130366Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 16 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:49.3134507Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:49.3135030Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:49.3136605Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:49.3137363Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:49.3138131Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:49.3148092Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2024]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:50.3135775Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:50.3137092Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:50.3137463Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:50.3137884Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:50.3443916Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2046ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:50.3448772Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:50.3449808Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:50.6123908Z|FAIL|rdkafka#consumer-2|[[thrd:GroupCoordinator]: GroupCoordinator: host.docker.internal:9092: Connect to ipv4#192.168.1.39:9092 failed: No connection could be made because the target machine actively refused it... (after 2022ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:50.6128871Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: GroupCoordinator: host.docker.internal:9092: Connect to ipv4#192.168.1.39:9092 failed: No connection could be made because the target machine actively refused it... (after 2022ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:51.0845160Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2039ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:51.0858790Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2039ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:51.3169611Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:51.3170995Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:51.3171323Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 16 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:51.3172708Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:51.3173107Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:51.3173789Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:51.3174111Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:51.3174332Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:51.3179088Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 1992]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:51.3640332Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2050ms in state CONNECT) (_TRANSPORT)]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:51.3657401Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2050ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:51.3666553Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:36:51.3667191Z|ERROR|rdkafka#producer-1|[[thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2050ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:51.3668267Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:52.3306343Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:52.3310271Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:52.3311739Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 17 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:52.3316671Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:52.3317467Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:52.3321726Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:52.3323054Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:52.3323925Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:52.3336409Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2024]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:53.2864535Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2031ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:53.2889733Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2031ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:53.3334464Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:53.3337284Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:53.3338287Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:53.3339321Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:53.3638449Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2046ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:53.3639699Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:53.3640110Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:54.3471280Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:54.3479369Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:54.3480765Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 17 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:54.3484280Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:54.3485492Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:54.3488096Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:54.3489099Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:54.3490122Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:54.3501045Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 2064]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:54.3782639Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2045ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:54.3783790Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:54.3784119Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:55.3498009Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:55.3514540Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:55.3516122Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 18 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:55.3519217Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:55.3519776Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:55.3521586Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:55.3522449Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:55.3523036Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:55.3532258Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2072]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:55.6452524Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2062ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:36:55.6459740Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2062ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:56.3629301Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:56.3633351Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:56.3634681Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:56.3635579Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:56.3944411Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2045ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:56.3954042Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:56.3955268Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:57.3689538Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:57.3693163Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:57.3694217Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 18 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:57.3697071Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:57.3698102Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:57.3700767Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:57.3701867Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:57.3702805Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:57.3713966Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 2088]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:57.3849849Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2032ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:57.3853539Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:57.3854830Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:58.3843148Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:58.3867619Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:58.3876237Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 19 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:58.3880407Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:58.3881939Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:58.3884194Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:58.3885075Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:58.3885695Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:58.3896252Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2072]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:59.3993815Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:59.4006584Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:59.4009904Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:59.4011285Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:59.4153189Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2044ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:59.4156747Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:36:59.4158604Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
warn: My.Logger[0]
Consumer Log Handler : WARNING|09-12-2022T17:37:00.1353973Z|COMMITFAIL|rdkafka#consumer-2|[[thrd:main]: Offset commit (unassigned partitions) failed for 1/1 partition(s) in join-state wait-unassign-to-complete: Local: Waiting for coordinator: my-consumer-topic[0]@10087(Local: Waiting for coordinator)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:00.3677402Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2045ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:00.3686665Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2045ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:00.4149705Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:00.4168519Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:00.4170590Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 19 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:00.4173716Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:00.4174406Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:00.4177399Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:00.4178336Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:00.4179022Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:00.4188350Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 2024]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:00.4307506Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2042ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:00.4310878Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:00.4312731Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:01.4274254Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:01.4282564Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:01.4284019Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 20 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:01.4287258Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:01.4288581Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:01.4291782Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:01.4293360Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:01.4294304Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:01.4305108Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2072]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:02.4289097Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:02.4292535Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:02.4293832Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:02.4294593Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:02.4600546Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2042ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:02.4612250Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:02.4614777Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:02.6160046Z|FAIL|rdkafka#consumer-2|[[thrd:GroupCoordinator]: GroupCoordinator: host.docker.internal:9092: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2044ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:02.6172299Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: GroupCoordinator: host.docker.internal:9092: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2044ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:02.7083647Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2057ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:02.7091972Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2057ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:03.4429670Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:03.4434250Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:03.4435685Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 20 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:03.4440174Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:03.4441487Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:03.4444956Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:03.4446298Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:03.4447678Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:03.4459765Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 1576]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:03.4596521Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2030ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:03.4600584Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:03.4602301Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:04.4548507Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:04.4564102Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:04.4570505Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 21 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:04.4575050Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:04.4575516Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:04.4577445Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:04.4578395Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:04.4579050Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:04.4587853Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2072]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:05.2364085Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2056ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:05.2377610Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2056ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:05.4699131Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:05.4713673Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:05.4716175Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:05.4717984Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:05.5169626Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2072ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:05.5173284Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:05.5174806Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:06.4825361Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:06.4847445Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:06.4853492Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 21 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:06.4856464Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:06.4857002Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:06.4858250Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:06.4859175Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:06.4859749Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:06.4868431Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 2080]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:06.4986942Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: No connection could be made because the target machine actively refused it... (after 2040ms in state CONNECT) (_TRANSPORT)]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:37:06.4989825Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: No connection could be made because the target machine actively refused it... (after 2040ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:06.4999630Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:37:06.5000464Z|ERROR|rdkafka#producer-1|[[thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: No connection could be made because the target machine actively refused it... (after 2040ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:06.5001394Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:07.4078636Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2031ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:07.4091182Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2031ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:07.4861760Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:07.4865909Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:07.4867172Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 22 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:07.4871009Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:07.4872402Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:07.4875757Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:07.4876923Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:07.4877671Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:07.4889139Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2072]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:08.4974978Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:08.4995460Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:08.4998551Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:08.5000148Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:08.5441889Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2058ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:08.5445214Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:08.5446633Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:09.5138617Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:09.5147237Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:09.5148677Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 22 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:09.5151987Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:09.5152829Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:09.5154135Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:09.5155527Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:09.5156157Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:09.5166566Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 828]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:09.5293971Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2041ms in state CONNECT) (_TRANSPORT)]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:37:09.5297100Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2041ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:09.5306431Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:37:09.5307085Z|ERROR|rdkafka#producer-1|[[thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2041ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:09.5308268Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:10.5230501Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:10.5247781Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:10.5249452Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 23 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:10.5252548Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:10.5253433Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:10.5255379Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:10.5256246Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:10.5257188Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:10.5266920Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 1576]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:11.5385871Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:11.5409341Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:11.5411424Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:11.5412458Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:11.5543074Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2038ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:11.5546914Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:11.5548361Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:12.5537304Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:12.5544919Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:12.5546919Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 23 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:12.5550458Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:12.5551167Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:12.5553206Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:12.5554418Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:12.5555076Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:12.5565297Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 2080]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:12.5854270Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2059ms in state CONNECT, 1 identical error(s) suppressed) (_TRANSPORT): identical to last error]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:37:12.5859131Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2059ms in state CONNECT, 1 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:12.5869962Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:37:12.5870837Z|ERROR|rdkafka#producer-1|[[thrd:app]: rdkafka#producer-1: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2059ms in state CONNECT, 1 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:12.5872250Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:13.5552118Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:13.5555395Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:13.5557177Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 24 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:13.5560486Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:13.5561411Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:13.5564259Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:13.5565319Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:13.5566047Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:13.5576216Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 1576]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:14.4887977Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2045ms in state CONNECT, 3 identical error(s) suppressed)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:14.4913818Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2045ms in state CONNECT, 3 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:14.5659289Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:14.5662895Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:14.5664420Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:14.5665281Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:14.5981412Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2042ms in state CONNECT, 10 identical error(s) suppressed) (_TRANSPORT): identical to last error]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:37:14.5985208Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2042ms in state CONNECT, 10 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:14.5996596Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
fail: My.Logger[0]
Producer Log Handler : ERROR|09-12-2022T17:37:14.5996613Z|ERROR|rdkafka#producer-1|[[thrd:app]: rdkafka#producer-1: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2042ms in state CONNECT, 10 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:14.5998920Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:14.6765311Z|FAIL|rdkafka#consumer-2|[[thrd:GroupCoordinator]: GroupCoordinator: host.docker.internal:9092: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2045ms in state CONNECT, 1 identical error(s) suppressed)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:14.6780098Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: GroupCoordinator: host.docker.internal:9092: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2045ms in state CONNECT, 1 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:15.5685145Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:15.5707802Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:15.5710945Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 24 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:15.5715408Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:15.5716184Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:15.5718869Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:15.5720016Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:15.5721393Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:15.5732327Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 820]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:15.5992060Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2042ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:15.5995380Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:15.5997221Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:16.5802020Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:16.5805794Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:16.5807548Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 25 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:16.5811364Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:16.5812061Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:16.5814108Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:16.5815096Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:16.5815803Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:16.5828302Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2080]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:16.9083161Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2059ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:16.9090656Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2059ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:17.5841970Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:17.5846085Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:17.5847574Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:17.5848407Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:17.6313212Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2059ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:17.6327732Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:17.6332065Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:18.2869664Z|FAIL|rdkafka#consumer-2|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2034ms in state CONNECT, 3 identical error(s) suppressed)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:18.2881402Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2034ms in state CONNECT, 3 identical error(s) suppressed)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:18.5987070Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:18.5988805Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:18.5989360Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 25 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:18.5990675Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:18.5991127Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:18.5991661Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:18.5992052Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:18.5992274Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:18.5997275Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 1992]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:18.6307329Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2049ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:18.6308075Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:18.6308504Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:19.6108305Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:19.6124580Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:19.6127953Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 26 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:19.6132408Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:19.6132818Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:19.6136205Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:19.6137383Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:19.6138182Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:19.6147096Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2096]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:20.6212557Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:20.6216488Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:20.6217185Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:20.6217550Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:20.6365069Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2037ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:20.6366422Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:20.6366752Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:21.5400821Z|FAIL|rdkafka#consumer-2|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2053ms in state CONNECT)]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:21.5412238Z|ERROR|rdkafka#consumer-2|[[thrd:app]: rdkafka#consumer-2: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Unknown error (after 2053ms in state CONNECT)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:21.6332579Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:21.6353386Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:21.6355890Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 26 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:21.6360085Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:21.6360583Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:21.6363712Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:21.6364929Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:21.6365552Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:21.6375857Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 1572]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:21.6647942Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2050ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:21.6649737Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:21.6650737Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:22.6464094Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:22.6473073Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:22.6474513Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 27 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:22.6478608Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:22.6479481Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:22.6481453Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:22.6482422Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:22.6486286Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:22.6496867Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2040]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:23.6534280Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:23.6537643Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:23.6538731Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:23.6540033Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:23.6690689Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2032ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:23.6706170Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:23.6715284Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:24.6590189Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:24.6591963Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:24.6592525Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 27 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:24.6594448Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:24.6595029Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:24.6596586Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:24.6598396Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:24.6598977Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:24.6604931Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 1120]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:24.7058944Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2057ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:24.7071738Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:24.7073483Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:25.6595371Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:25.6598251Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:25.6599292Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 28 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:25.6602911Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:25.6603580Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:25.6605618Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:25.6606427Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:25.6607380Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:25.6616995Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2040]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:26.6745271Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:26.6760320Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:26.6763582Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:26.6767478Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:26.7065148Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2046ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:26.7068160Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:26.7069620Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:27.6886729Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:27.6895186Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:27.6896571Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 28 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:27.6900414Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:27.6901005Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:27.6904619Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:27.6905740Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:27.6906546Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:27.6918679Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 1992]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:27.7044957Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2043ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:27.7048661Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:27.7049875Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:28.7018110Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:28.7034449Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:28.7038718Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 29 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:28.7041671Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:28.7041835Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:28.7043409Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:28.7044443Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:28.7044802Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:28.7052054Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 2084]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:29.7181127Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:29.7187407Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:29.7190008Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:29.7190785Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:29.7497073Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2058ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:29.7500347Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:29.7501627Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:30.7305776Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:30.7321073Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:30.7322266Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 29 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:30.7324549Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:30.7325746Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:30.7327368Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:30.7328219Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:30.7328829Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:30.7338273Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 828]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:30.7469414Z|FAIL|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Unknown error (after 2042ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:30.7475352Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:30.7476679Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:31.7396730Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:31.7404044Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:31.7405029Z|CONNECT|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: Selected for cluster connection: refresh unavailable topics (broker has 30 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:31.7407197Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:31.7407340Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:31.7408916Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:31.7409453Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:31.7409718Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:31.7413826Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 824]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:32.7557877Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:32.7563224Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:32.7564884Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Cluster connection already in progress: refresh unavailable topics]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:32.7565563Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:32.7718810Z|FAIL|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connect to ipv4#192.168.1.39:9092 failed: Unknown error (after 2038ms in state CONNECT) (_TRANSPORT): identical to last error: error log suppressed]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:32.7720009Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> DOWN]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:32.7720423Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state DOWN -> INIT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7684808Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7686908Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7687677Z|CONNECT|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: Selected for cluster connection: refresh unavailable topics (broker has 30 connection attempt(s))]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7687491Z|CONNECT|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected to ipv4#127.0.0.1:9092]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7688952Z|CONNECTED|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connected (#2)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7689354Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7689623Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received CONNECT op]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7689686Z|CONNECT|rdkafka#producer-1|[[thrd:main]: Not selecting any broker for cluster connection: still suppressed for 49ms: no cluster connection]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7690329Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state INIT -> TRY_CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7690922Z|SEND|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent ApiVersionRequest (v3, 52 bytes @ 0, CorrId 3)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7691412Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: broker in state TRY_CONNECT connecting]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7692082Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state TRY_CONNECT -> CONNECT]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7698558Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connecting to ipv4#192.168.1.39:9092 (plaintext) with socket 2112]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7703220Z|CONNECT|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connected to ipv4#192.168.1.39:9092]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7708335Z|CONNECTED|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Connected (#1)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7708987Z|FEATURE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Updated enabled protocol features +ApiVersion to ApiVersion]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7709449Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state CONNECT -> APIVERSION_QUERY]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7711226Z|SEND|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Sent ApiVersionRequest (v3, 52 bytes @ 0, CorrId 1)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7717679Z|RECV|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received ApiVersionResponse (v3, 431 bytes, CorrId 3, rtt 2.66ms)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7718771Z|STATE|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7720602Z|SEND|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Sent MetadataRequest (v4, 48 bytes @ 0, CorrId 4)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7724470Z|RECV|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received ApiVersionResponse (v3, 431 bytes, CorrId 1, rtt 1.30ms)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7725561Z|FEATURE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7726207Z|STATE|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Broker changed state APIVERSION_QUERY -> UP]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7820155Z|RECV|rdkafka#producer-1|[[thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received MetadataResponse (v4, 101 bytes, CorrId 4, rtt 9.93ms)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7822802Z|METADATA|rdkafka#producer-1|[[thrd:main]: Error in metadata reply for topic my-producer-topic (PartCnt 0): Broker: Unknown topic or partition]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7823656Z|STATE|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic changed state unknown -> notexists]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7824069Z|PARTCNT|rdkafka#producer-1|[[thrd:main]: Failing all 1 unassigned messages in topic my-producer-topic since topic does not exist: Broker: Unknown topic or partition]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7824322Z|UAS|rdkafka#producer-1|[[thrd:main]: 0/1 messages were partitioned in topic my-producer-topic]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7824690Z|UAS|rdkafka#producer-1|[[thrd:main]: 1/1 messages failed partitioning in topic my-producer-topic]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:33.7825059Z|METADATA|rdkafka#producer-1|[[thrd:main]: localhost:9092/bootstrap: 1/1 requested topic(s) seen in metadata]
info: My.Logger[0]
Elapsed time : 96880 ms
info: My.Logger[0]
Message produced to Topic: my-producer-topic, Offset: -1001,
Exception Message: Broker: Unknown topic or partition,
Exception Source: Platform.IMS.Messaging,
Exception InnerException:
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:34.7773388Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic metadata information timed out (995ms old)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:34.7777078Z|STATE|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic changed state notexists -> unknown]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:34.7778227Z|NOINFO|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count is zero: should refresh metadata]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:34.7787101Z|SEND|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Sent MetadataRequest (v4, 48 bytes @ 0, CorrId 2)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:34.7814600Z|RECV|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Received MetadataResponse (v4, 127 bytes, CorrId 2, rtt 2.75ms)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:34.7817967Z|STATE|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic changed state unknown -> exists]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:34.7820306Z|PARTCNT|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition count changed from 0 to 1]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:34.7821566Z|TOPPARNEW|rdkafka#producer-1|[[thrd:main]: NEW my-producer-topic [0] 000001E2B68D3FA0 refcnt 000001E2B68D4030 (at rd_kafka_topic_partition_cnt_update:798)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:34.7822294Z|METADATA|rdkafka#producer-1|[[thrd:main]: Topic my-producer-topic partition 0 Leader 0]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:34.7823445Z|BRKDELGT|rdkafka#producer-1|[[thrd:main]: my-producer-topic [0]: delegate to broker host.docker.internal:9092/0 (rktp 000001E2B68D3FA0, term 0, ref 2)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:34.7824177Z|BRKDELGT|rdkafka#producer-1|[[thrd:main]: my-producer-topic [0]: delegating to broker host.docker.internal:9092/0 for partition with 0 messages (0 bytes) queued]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:34.7824965Z|BRKMIGR|rdkafka#producer-1|[[thrd:main]: Migrating topic my-producer-topic [0] 000001E2B68D3FA0 from (none) to host.docker.internal:9092/0 (sending PARTITION_JOIN to host.docker.internal:9092/0)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:34.7827464Z|PARTCNT|rdkafka#producer-1|[[thrd:main]: Partitioning 0 unassigned messages in topic my-producer-topic to 1 partitions]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:34.7828117Z|TOPBRK|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Topic my-producer-topic [0]: joining broker (rktp 000001E2B68D3FA0, 0 message(s) queued)]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:34.7828725Z|UAS|rdkafka#producer-1|[[thrd:main]: 0/0 messages were partitioned in topic my-producer-topic]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:34.7829872Z|FETCHADD|rdkafka#producer-1|[[thrd:host.docker.internal:9092/0]: host.docker.internal:9092/0: Added my-producer-topic [0] to active list (1 entries, opv 0, 0 messages queued): joining]
dbug: My.Logger[0]
Producer Log Handler : DEBUG|09-12-2022T17:37:34.7831565Z|METADATA|rdkafka#producer-1|[[thrd:main]: host.docker.internal:9092/0: 1/1 requested topic(s) seen in metadata]
trce: My.Logger[0]
Consumer Log Handler : NOTICE|09-12-2022T17:37:57.1347149Z|REQTMOUT|rdkafka#consumer-2|[[thrd:GroupCoordinator]: GroupCoordinator/0: Timed out LeaveGroupRequest in flight (after 5044ms, timeout #0): possibly held back by preceeding blocking JoinGroupRequest with timeout in 280519ms]
warn: My.Logger[0]
Consumer Log Handler : WARNING|09-12-2022T17:37:57.1351131Z|REQTMOUT|rdkafka#consumer-2|[[thrd:GroupCoordinator]: GroupCoordinator/0: Timed out 1 in-flight, 0 retry-queued, 0 out-queue, 0 partially-sent requests]
fail: My.Logger[0]
Consumer Log Handler : ERROR|09-12-2022T17:37:57.1356009Z|FAIL|rdkafka#consumer-2|[[thrd:GroupCoordinator]: GroupCoordinator: 1 request(s) timed out: disconnect (after 22496ms in state UP)]
info: My.Logger[0]
Stop async called

`

ksdvishnukumar Feb 9, 2023
Author

@edenhill & @mhowlett ,

Could you please provide thoughts on this. Appreciate your time on this.

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Kafka Message loss when Kafkaserver goes down #4099

{{title}}

{{editor}}'s edit

{{editor}}'s edit

Replies: 1 comment 6 replies

{{title}}

{{title}}

{{title}}

{{editor}}'s edit

{{editor}}'s edit

{{title}}

{{title}}

{{editor}}'s edit

{{editor}}'s edit

{{title}}

Select a reply

Kafka Message loss when Kafkaserver goes down #4099

ksdvishnukumar Dec 8, 2022

Replies: 1 comment · 6 replies

edenhill Dec 8, 2022

edenhill Dec 8, 2022

ksdvishnukumar Dec 8, 2022 Author

ksdvishnukumarcse Dec 9, 2022

ksdvishnukumar Dec 9, 2022 Author

ksdvishnukumar Feb 9, 2023 Author

ksdvishnukumar
Dec 8, 2022

Replies: 1 comment 6 replies

edenhill
Dec 8, 2022

ksdvishnukumar Dec 8, 2022
Author

ksdvishnukumar Dec 9, 2022
Author

ksdvishnukumar Feb 9, 2023
Author