edenhill / kcat

Generic command line non-JVM Apache Kafka producer and consumer
Other
5.41k stars 484 forks source link

Hang on trying produce with -l option #446

Open Hubbitus opened 6 months ago

Hubbitus commented 6 months ago

I've use kcat from master branch and trying produce messages like:

echo "key1:body1" | kcat -d all -m30 -b ... -P -e -t tmp.dev.1 -K: -D'\n' -l /dev/stdin

and that command just hangs and never returns, messages also not produced. I've tried with regular file (not pipe and /dev/stdin), but that it the same.

What interesting, that work in 1.7.1 version (container docker.io/edenhill/kcat:1.7.1).

$ ./_kafkacat.sh -V
kcat - Apache Kafka producer and consumer tool
https://github.com/edenhill/kcat
Copyright (c) 2014-2021, Magnus Edenhill
Version 1.7.1 (JSON, Avro, Transactions, IncrementalAssign, JSONVerbatim, librdkafka 1.8.2 builtin.features=gzip,snappy,ssl,sasl,regex,lz4,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer)

In debug (with -d all) I can configrm what producer initialized, but no attempts to parse file and producing performed:

%7|1711291830.921|SASL|rdkafka#producer-1| [thrd:app]: Selected provider SCRAM (builtin) for SASL mechanism SCRAM-SHA-512
%7|1711291830.921|OPENSSL|rdkafka#producer-1| [thrd:app]: Using OpenSSL version OpenSSL 1.1.1k  25 Mar 2021 (0x101010bf, librdkafka built with 0x101010bf)
%7|1711291830.924|SSL|rdkafka#producer-1| [thrd:app]: Loading CA certificate(s) from file /conf/truststore.cer.pem
%7|1711291830.925|WAKEUPFD|rdkafka#producer-1| [thrd:app]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Enabled low-latency ops queue wake-ups
%7|1711291830.925|BRKMAIN|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Enter main broker thread
%7|1711291830.925|BROKER|rdkafka#producer-1| [thrd:app]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Added new broker with NodeId -1
%7|1711291830.925|WAKEUPFD|rdkafka#producer-1| [thrd:app]: sasl_ssl://haproxy-kafka-dev.gid.team:39092/bootstrap: Enabled low-latency ops queue wake-ups
%7|1711291830.925|BRKMAIN|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Enter main broker thread
%7|1711291830.925|BROKER|rdkafka#producer-1| [thrd:app]: sasl_ssl://haproxy-kafka-dev.gid.team:39092/bootstrap: Added new broker with NodeId -1
%7|1711291830.925|WAKEUPFD|rdkafka#producer-1| [thrd:app]: sasl_ssl://haproxy-kafka-dev.gid.team:39093/bootstrap: Enabled low-latency ops queue wake-ups
%7|1711291830.925|BRKMAIN|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39092/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39092/bootstrap: Enter main broker thread
%7|1711291830.925|BROKER|rdkafka#producer-1| [thrd:app]: sasl_ssl://haproxy-kafka-dev.gid.team:39093/bootstrap: Added new broker with NodeId -1
%7|1711291830.925|CONNECT|rdkafka#producer-1| [thrd:app]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s))
%7|1711291830.925|INIT|rdkafka#producer-1| [thrd:app]: librdkafka v1.8.2 (0x10802ff) rdkafka#producer-1 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, GCC GXX PKGCONFIG GNULD C11THREADS LIBDL PLUGINS ZLIB SSL ZSTD HDRHISTOGRAM SYSLOG SNAPPY SOCKEM SASL_SCRAM SASL_OAUTHBEARER CRC32C_HW, debug 0xfffff)
%7|1711291830.925|BRKMAIN|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39093/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39093/bootstrap: Enter main broker thread
%7|1711291830.925|CONF|rdkafka#producer-1| [thrd:app]: Client configuration:
%7|1711291830.925|CONF|rdkafka#producer-1| [thrd:app]:   client.software.version = 1.8.2
%7|1711291830.925|CONF|rdkafka#producer-1| [thrd:app]:   metadata.broker.list = haproxy-kafka-dev.gid.team:39091,haproxy-kafka-dev.gid.team:39092,haproxy-kafka-dev.gid.team:39093
%7|1711291830.925|CONF|rdkafka#producer-1| [thrd:app]:   debug = generic,broker,topic,metadata,feature,queue,msg,protocol,cgrp,security,fetch,interceptor,plugin,consumer,admin,eos,mock,assignor,conf,all
%7|1711291830.925|CONF|rdkafka#producer-1| [thrd:app]:   error_cb = 0x5639af522560
%7|1711291830.925|CONF|rdkafka#producer-1| [thrd:app]:   throttle_cb = 0x5639af51e7f0
%7|1711291830.926|CONF|rdkafka#producer-1| [thrd:app]:   log_cb = 0x5639af54aef0
%7|1711291830.925|CONNECT|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Received CONNECT op
%7|1711291830.926|STATE|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Broker changed state INIT -> TRY_CONNECT
%7|1711291830.926|BROADCAST|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: Broadcasting state change
%7|1711291830.926|CONNECT|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: broker in state TRY_CONNECT connecting
%7|1711291830.926|STATE|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
%7|1711291830.926|BROADCAST|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: Broadcasting state change
%7|1711291830.926|CONF|rdkafka#producer-1| [thrd:app]:   internal.termination.signal = 29
%7|1711291830.926|CONF|rdkafka#producer-1| [thrd:app]:   security.protocol = sasl_ssl
%7|1711291830.926|CONF|rdkafka#producer-1| [thrd:app]:   ssl.ca.location = /conf/truststore.cer.pem
%7|1711291830.926|CONF|rdkafka#producer-1| [thrd:app]:   sasl.mechanisms = SCRAM-SHA-512
%7|1711291830.926|CONF|rdkafka#producer-1| [thrd:app]:   sasl.username = [redacted]
%7|1711291830.926|CONF|rdkafka#producer-1| [thrd:app]:   sasl.password = [redacted]
%7|1711291830.926|CONF|rdkafka#producer-1| [thrd:app]:   dr_msg_cb = 0x5639af51e920
%7|1711291830.926|TOPIC|rdkafka#producer-1| [thrd:app]: New local topic: tmp.dev.1
%7|1711291830.926|TOPPARNEW|rdkafka#producer-1| [thrd:app]: NEW tmp.dev.1 [-1] 0x7f0ee2f36500 refcnt 0x7f0ee2f36590 (at rd_kafka_topic_new0:465)
%7|1711291830.926|CONNECT|rdkafka#producer-1| [thrd:app]: Not selecting any broker for cluster connection: still suppressed for 49ms: leader query
%7|1711291830.926|METADATA|rdkafka#producer-1| [thrd:app]: Hinted cache of 1/1 topic(s) being queried
%7|1711291830.926|METADATA|rdkafka#producer-1| [thrd:app]: Skipping metadata refresh of 1 topic(s): leader query: no usable brokers
%7|1711291830.943|CONNECT|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Connecting to ipv4#10.223.0.49:39091 (sasl_ssl) with socket 12
%7|1711291830.950|CONNECT|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Connected to ipv4#10.223.0.49:39091
%7|1711291830.951|STATE|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Broker changed state CONNECT -> SSL_HANDSHAKE
%7|1711291830.951|BROADCAST|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: Broadcasting state change
%7|1711291830.966|SSLVERIFY|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Broker SSL certificate verified
%7|1711291830.966|CONNECTED|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Connected (#1)
%7|1711291830.966|FEATURE|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1711291830.966|STATE|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Broker changed state SSL_HANDSHAKE -> APIVERSION_QUERY
%7|1711291830.966|BROADCAST|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: Broadcasting state change
%7|1711291830.966|SEND|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Sent ApiVersionRequest (v3, 40 bytes @ 0, CorrId 1)
%7|1711291831.023|RECV|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Received ApiVersionResponse (v3, 438 bytes, CorrId 1, rtt 57.11ms)
%7|1711291831.023|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Broker API support:
%7|1711291831.023|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey Produce (0) Versions 0..9
%7|1711291831.023|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey Fetch (1) Versions 0..15
%7|1711291831.023|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey ListOffsets (2) Versions 0..8
%7|1711291831.023|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey Metadata (3) Versions 0..12
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey LeaderAndIsr (4) Versions 0..7
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey StopReplica (5) Versions 0..4
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey UpdateMetadata (6) Versions 0..8
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey ControlledShutdown (7) Versions 0..3
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey OffsetCommit (8) Versions 0..8
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey OffsetFetch (9) Versions 0..8
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey FindCoordinator (10) Versions 0..4
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey JoinGroup (11) Versions 0..9
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey Heartbeat (12) Versions 0..4
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey LeaveGroup (13) Versions 0..5
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey SyncGroup (14) Versions 0..5
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey DescribeGroups (15) Versions 0..5
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey ListGroups (16) Versions 0..4
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey SaslHandshake (17) Versions 0..1
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey ApiVersion (18) Versions 0..3
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey CreateTopics (19) Versions 0..7
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey DeleteTopics (20) Versions 0..6
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey DeleteRecords (21) Versions 0..2
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey InitProducerId (22) Versions 0..4
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey OffsetForLeaderEpoch (23) Versions 0..4
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey AddPartitionsToTxn (24) Versions 0..3
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey AddOffsetsToTxn (25) Versions 0..3
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey EndTxn (26) Versions 0..3
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey WriteTxnMarkers (27) Versions 0..1
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey DescribeAcls (29) Versions 0..3
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey CreateAcls (30) Versions 0..3
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey DeleteAcls (31) Versions 0..3
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey DescribeConfigs (32) Versions 0..4
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey AlterConfigs (33) Versions 0..2
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey AlterReplicaLogDirs (34) Versions 0..2
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey DescribeLogDirs (35) Versions 0..4
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey SaslAuthenticate (36) Versions 0..2
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey CreatePartitions (37) Versions 0..3
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey CreateDelegationToken (38) Versions 0..3
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey RenewDelegationToken (39) Versions 0..2
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey ExpireDelegationToken (40) Versions 0..2
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey DescribeDelegationToken (41) Versions 0..3
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey DeleteGroups (42) Versions 0..2
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey ElectLeadersRequest (43) Versions 0..2
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey IncrementalAlterConfigsRequest (44) Versions 0..1
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey AlterPartitionReassignmentsRequest (45) Versions 0..0
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey ListPartitionReassignmentsRequest (46) Versions 0..0
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey OffsetDeleteRequest (47) Versions 0..0
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey DescribeClientQuotasRequest (48) Versions 0..1
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey AlterClientQuotasRequest (49) Versions 0..1
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey DescribeUserScramCredentialsRequest (50) Versions 0..0
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey AlterUserScramCredentialsRequest (51) Versions 0..0
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey AlterIsrRequest (56) Versions 0..3
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey UpdateFeaturesRequest (57) Versions 0..1
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey EnvelopeRequest (58) Versions 0..0
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey Unknown-60? (60) Versions 0..0
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey Unknown-61? (61) Versions 0..0
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey Unknown-65? (65) Versions 0..0
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey Unknown-66? (66) Versions 0..0
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   ApiKey Unknown-67? (67) Versions 0..0
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Enabling feature MsgVer1
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Enabling feature MsgVer2
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Enabling feature ApiVersion
%7|1711291831.024|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Enabling feature BrokerGroupCoordinator
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Enabling feature BrokerBalancedConsumer
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Enabling feature ThrottleTime
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Enabling feature Sasl
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Enabling feature SaslHandshake
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature LZ4: FindCoordinator (0..0) supported by broker
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Enabling feature LZ4
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature OffsetTime: ListOffsets (1..1) supported by broker
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Enabling feature OffsetTime
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Enabling feature IdempotentProducer
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature ZSTD: Produce (7..7) supported by broker
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature ZSTD: Fetch (10..10) supported by broker
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Enabling feature ZSTD
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:  Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker
%7|1711291831.025|APIVERSION|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Enabling feature SaslAuthReq
%7|1711291831.025|FEATURE|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
%7|1711291831.025|AUTH|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Auth in state APIVERSION_QUERY (handshake supported)
%7|1711291831.025|STATE|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Broker changed state APIVERSION_QUERY -> AUTH_HANDSHAKE
%7|1711291831.025|BROADCAST|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: Broadcasting state change
%7|1711291831.025|SEND|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Sent SaslHandshakeRequest (v1, 36 bytes @ 0, CorrId 2)
%7|1711291831.076|RECV|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Received SaslHandshakeResponse (v1, 21 bytes, CorrId 2, rtt 50.60ms)
%7|1711291831.076|SASLMECHS|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Broker supported SASL mechanisms: SCRAM-SHA-512
%7|1711291831.076|AUTH|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Auth in state AUTH_HANDSHAKE (handshake supported)
%7|1711291831.076|STATE|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Broker changed state AUTH_HANDSHAKE -> AUTH_REQ
%7|1711291831.076|BROADCAST|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: Broadcasting state change
%7|1711291831.076|SASL|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Initializing SASL client: service name kafka, hostname haproxy-kafka-dev.gid.team, mechanisms SCRAM-SHA-512, provider SCRAM (builtin)
%7|1711291831.076|SASLSCRAM|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: SASL SCRAM client in state client-first-message
%7|1711291831.076|SASL|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Send SASL Kafka frame to broker (58 bytes)
%7|1711291831.076|SEND|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Sent SaslAuthenticateRequest (v0, 83 bytes @ 0, CorrId 3)
%7|1711291831.083|RECV|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Received SaslAuthenticateResponse (v0, 101 bytes, CorrId 3, rtt 7.34ms)
%7|1711291831.083|SASL|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Received SASL frame from broker (93 bytes)
%7|1711291831.083|SASLSCRAM|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: SASL SCRAM client in state server-first-message
%7|1711291831.107|SASL|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Send SASL Kafka frame to broker (189 bytes)
%7|1711291831.107|SEND|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Sent SaslAuthenticateRequest (v0, 214 bytes @ 0, CorrId 4)
%7|1711291831.115|RECV|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Received SaslAuthenticateResponse (v0, 98 bytes, CorrId 4, rtt 8.42ms)
%7|1711291831.115|SASL|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Received SASL frame from broker (90 bytes)
%7|1711291831.115|SASLSCRAM|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: SASL SCRAM client in state client-final-message
%7|1711291831.115|SCRAMAUTH|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: SASL SCRAM authentication successful on server: verifying ServerSignature
%7|1711291831.115|SCRAMAUTH|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Authenticated as dev_data_team_user using SCRAM-SHA-512
%7|1711291831.115|STATE|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Broker changed state AUTH_REQ -> UP
%7|1711291831.115|BROADCAST|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: Broadcasting state change
%7|1711291831.115|METADATA|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: Hinted cache of 1/1 topic(s) being queried
%7|1711291831.115|METADATA|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: Requesting metadata for 1/1 topics: connected
%7|1711291831.115|METADATA|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Request metadata for 1 topic(s): connected
%7|1711291831.115|SEND|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Sent MetadataRequest (v4, 37 bytes @ 0, CorrId 5)
%7|1711291831.123|RECV|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: Received MetadataResponse (v4, 213 bytes, CorrId 5, rtt 7.32ms)
%7|1711291831.123|METADATA|rdkafka#producer-1| [thrd:main]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: ===== Received metadata (for 1 requested topics): connected =====
%7|1711291831.123|METADATA|rdkafka#producer-1| [thrd:main]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: ClusterId: qEYrvERoSyyUzs7CdrhRyg, ControllerId: 1
%7|1711291831.123|METADATA|rdkafka#producer-1| [thrd:main]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: 3 brokers, 1 topics
%7|1711291831.123|METADATA|rdkafka#producer-1| [thrd:main]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap:   Broker #0/3: haproxy-kafka-dev.gid.team:39091 NodeId 0
%7|1711291831.123|UPDATE|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap: NodeId changed from -1 to 0
%7|1711291831.123|UPDATE|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/0: Name changed from sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap to sasl_ssl://haproxy-kafka-dev.gid.team:39091/0
%7|1711291831.123|LEADER|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/0: Mapped 0 partition(s) to broker
%7|1711291831.123|STATE|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/0: Broker changed state UP -> UPDATE
%7|1711291831.123|BROADCAST|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: Broadcasting state change
%7|1711291831.123|BROADCAST|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: Broadcasting state change
%7|1711291831.123|STATE|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/0: Broker changed state UPDATE -> UP
%7|1711291831.123|BROADCAST|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: Broadcasting state change
%7|1711291831.123|METADATA|rdkafka#producer-1| [thrd:main]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/0:   Broker #1/3: haproxy-kafka-dev.gid.team:39093 NodeId 2
%7|1711291831.123|UPDATE|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39093/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39093/bootstrap: NodeId changed from -1 to 2
%7|1711291831.123|UPDATE|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39093/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39093/2: Name changed from sasl_ssl://haproxy-kafka-dev.gid.team:39093/bootstrap to sasl_ssl://haproxy-kafka-dev.gid.team:39093/2
%7|1711291831.123|LEADER|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39093/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39093/2: Mapped 0 partition(s) to broker
%7|1711291831.123|BROADCAST|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39093/bootstrap]: Broadcasting state change
%7|1711291831.123|METADATA|rdkafka#producer-1| [thrd:main]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/0:   Broker #2/3: haproxy-kafka-dev.gid.team:39092 NodeId 1
%7|1711291831.123|UPDATE|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39092/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39092/bootstrap: NodeId changed from -1 to 1
%7|1711291831.123|UPDATE|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39092/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39092/1: Name changed from sasl_ssl://haproxy-kafka-dev.gid.team:39092/bootstrap to sasl_ssl://haproxy-kafka-dev.gid.team:39092/1
%7|1711291831.123|LEADER|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39092/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39092/1: Mapped 0 partition(s) to broker
%7|1711291831.123|BROADCAST|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39092/bootstrap]: Broadcasting state change
%7|1711291831.124|METADATA|rdkafka#producer-1| [thrd:main]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/0:   Topic #0/1: tmp.dev.1 with 1 partitions
%7|1711291831.124|STATE|rdkafka#producer-1| [thrd:main]: Topic tmp.dev.1 changed state unknown -> exists
%7|1711291831.124|PARTCNT|rdkafka#producer-1| [thrd:main]: Topic tmp.dev.1 partition count changed from 0 to 1
%7|1711291831.124|TOPPARNEW|rdkafka#producer-1| [thrd:main]: NEW tmp.dev.1 [0] 0x5639afe7e100 refcnt 0x5639afe7e190 (at rd_kafka_topic_partition_cnt_update:798)
%7|1711291831.124|METADATA|rdkafka#producer-1| [thrd:main]:   Topic tmp.dev.1 partition 0 Leader 0
%7|1711291831.124|BRKDELGT|rdkafka#producer-1| [thrd:main]: tmp.dev.1 [0]: delegate to broker sasl_ssl://haproxy-kafka-dev.gid.team:39091/0 (rktp 0x5639afe7e100, term 0, ref 2)
%7|1711291831.124|BRKDELGT|rdkafka#producer-1| [thrd:main]: tmp.dev.1 [0]: delegating to broker sasl_ssl://haproxy-kafka-dev.gid.team:39091/0 for partition with 0 messages (0 bytes) queued
%7|1711291831.124|BRKMIGR|rdkafka#producer-1| [thrd:main]: Migrating topic tmp.dev.1 [0] 0x5639afe7e100 from (none) to sasl_ssl://haproxy-kafka-dev.gid.team:39091/0 (sending PARTITION_JOIN to sasl_ssl://haproxy-kafka-dev.gid.team:39091/0)
%7|1711291831.124|PARTCNT|rdkafka#producer-1| [thrd:main]: Partitioning 0 unassigned messages in topic tmp.dev.1 to 1 partitions
%7|1711291831.124|UAS|rdkafka#producer-1| [thrd:main]: 0/0 messages were partitioned in topic tmp.dev.1
%7|1711291831.124|METADATA|rdkafka#producer-1| [thrd:main]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/0: 1/1 requested topic(s) seen in metadata
%7|1711291831.124|CLUSTERID|rdkafka#producer-1| [thrd:main]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/0: ClusterId update "" -> "qEYrvERoSyyUzs7CdrhRyg"
%7|1711291831.124|CONTROLLERID|rdkafka#producer-1| [thrd:main]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/0: ControllerId update -1 -> 1
%7|1711291831.124|BROADCAST|rdkafka#producer-1| [thrd:main]: Broadcasting state change
%7|1711291831.124|TOPBRK|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/0: Topic tmp.dev.1 [0]: joining broker (rktp 0x5639afe7e100, 0 message(s) queued)
%7|1711291831.124|FETCHADD|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: sasl_ssl://haproxy-kafka-dev.gid.team:39091/0: Added tmp.dev.1 [0] to active list (1 entries, opv 0, 0 messages queued): joining
%7|1711291831.124|BROADCAST|rdkafka#producer-1| [thrd:sasl_ssl://haproxy-kafka-dev.gid.team:39091/bootstrap]: Broadcasting state change