Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Hang on trying produce with -l option #446

Open
Hubbitus opened this issue Mar 24, 2024 · 0 comments
Open

Hang on trying produce with -l option #446

Hubbitus opened this issue Mar 24, 2024 · 0 comments

Comments

@Hubbitus
Copy link

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
Hubbitus pushed a commit to Hubbitus/kafkacat that referenced this issue Mar 24, 2024
edenhill#446 revert back file read functionality into working state (…
7a30e5f 
…from tag 1.7.1)
Hubbitus pushed a commit to Hubbitus/kafkacat that referenced this issue Mar 24, 2024
Build new images hubbitus/kafkacat-sasl:20240324 with temp workaround…
6c621bd 
… of bug edenhill#446
Hubbitus pushed a commit to Hubbitus/kafka.scripts that referenced this issue Mar 24, 2024
Update image version to workaround of bug edenhill/kcat#446
8b6a505
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
1 participant
@Hubbitus