Timeouts on ARM (Apple M1) machine

[slashrsm]

• PHP version: 7.4.23
• librdkafka version: 1.6.0-1
• php-rdkafka version: 5.0.0
• kafka version: 2.8.0

I am running into timeouts when tying to use php-rdkafka on an ARM machine (inside a docker container). If I try to execute the official producer example I get the RD_KAFKA_RESP_ERR__TIMED_OUT error. I tried to increase the timeout argument to the ->flush() function, but that didn't help.

My colleague, that is using an Intel Mac, doesn't get the error with the same setup. I am also able to connect and communicate with Kafka when using longlang/phpkafka.

Anyone else experienced the same problem?

Debug log:

%7|1633540193.834|WAKEUPFD|rdkafka#producer-1| [thrd:app]: kafka:9092/bootstrap: Enabled low-latency ops queue wake-ups
%7|1633540193.834|BROKER|rdkafka#producer-1| [thrd:app]: kafka:9092/bootstrap: Added new broker with NodeId -1
%7|1633540193.834|BRKMAIN|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Enter main broker thread
%7|1633540193.834|CONNECT|rdkafka#producer-1| [thrd:app]: kafka:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s))
%7|1633540193.834|INIT|rdkafka#producer-1| [thrd:app]: librdkafka v1.6.0 (0x10600ff) rdkafka#producer-1 initialized (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, GCC GXX INSTALL GNULD LDS C11THREADS LIBDL PLUGINS ZLIB SSL SASL_CYRUS ZSTD HDRHISTOGRAM LZ4_EXT SYSLOG RAPIDJSON SNAPPY SOCKEM SASL_SCRAM SASL_OAUTHBEARER, debug 0xfffff)
%7|1633540193.834|CONF|rdkafka#producer-1| [thrd:app]: Client configuration:
%7|1633540193.834|CONF|rdkafka#producer-1| [thrd:app]:   client.software.version = 1.6.0
%7|1633540193.834|CONF|rdkafka#producer-1| [thrd:app]:   metadata.broker.list = kafka:9092
%7|1633540193.834|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|1633540193.834|CONF|rdkafka#producer-1| [thrd:app]:   log_level = 7
%7|1633540193.834|CONF|rdkafka#producer-1| [thrd:app]:   opaque = 0xffff708f7f10
%7|1633540193.834|CONF|rdkafka#producer-1| [thrd:app]:   ssl_key = [redacted]
%7|1633540193.834|CONF|rdkafka#producer-1| [thrd:app]:   dr_msg_cb = 0xffff924ab3d0
%7|1633540193.834|BRKMAIN|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Enter main broker thread
%7|1633540193.834|CONNECT|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Received CONNECT op
%7|1633540193.834|STATE|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT
%7|1633540193.834|BROADCAST|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: Broadcasting state change
%7|1633540193.834|CONNECT|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: broker in state TRY_CONNECT connecting
%7|1633540193.834|STATE|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT
%7|1633540193.834|BROADCAST|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: Broadcasting state change
%7|1633540193.834|CONNECT|rdkafka#producer-1| [thrd:app]: Not selecting any broker for cluster connection: still suppressed for 49ms: application metadata request
%7|1633540193.835|CONNECT|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Connecting to ipv4#172.18.0.8:9092 (plaintext) with socket 15
%7|1633540193.836|CONNECT|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Connected to ipv4#172.18.0.8:9092
%7|1633540193.836|CONNECTED|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Connected (#1)
%7|1633540193.836|FEATURE|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion
%7|1633540193.836|STATE|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY
%7|1633540193.836|BROADCAST|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: Broadcasting state change
%7|1633540193.836|CONNECT|rdkafka#producer-1| [thrd:app]: Not selecting any broker for cluster connection: still suppressed for 48ms: application metadata request
%7|1633540193.836|SEND|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Sent ApiVersionRequest (v3, 40 bytes @ 0, CorrId 1)
%7|1633540193.854|RECV|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Received ApiVersionResponse (v3, 410 bytes, CorrId 1, rtt 18.56ms)
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Broker API support:
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey Produce (0) Versions 0..9
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey Fetch (1) Versions 0..12
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey Offset (2) Versions 0..6
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey Metadata (3) Versions 0..11
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey LeaderAndIsr (4) Versions 0..5
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey StopReplica (5) Versions 0..3
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey UpdateMetadata (6) Versions 0..7
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey ControlledShutdown (7) Versions 0..3
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey OffsetCommit (8) Versions 0..8
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey OffsetFetch (9) Versions 0..7
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey FindCoordinator (10) Versions 0..3
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey JoinGroup (11) Versions 0..7
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey Heartbeat (12) Versions 0..4
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey LeaveGroup (13) Versions 0..4
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey SyncGroup (14) Versions 0..5
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey DescribeGroups (15) Versions 0..5
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey ListGroups (16) Versions 0..4
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey SaslHandshake (17) Versions 0..1
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey ApiVersion (18) Versions 0..3
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey CreateTopics (19) Versions 0..7
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey DeleteTopics (20) Versions 0..6
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey DeleteRecords (21) Versions 0..2
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey InitProducerId (22) Versions 0..4
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey OffsetForLeaderEpoch (23) Versions 0..4
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey AddPartitionsToTxn (24) Versions 0..3
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey AddOffsetsToTxn (25) Versions 0..3
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey EndTxn (26) Versions 0..3
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey WriteTxnMarkers (27) Versions 0..1
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey TxnOffsetCommit (28) Versions 0..3
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey DescribeAcls (29) Versions 0..2
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey CreateAcls (30) Versions 0..2
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey DeleteAcls (31) Versions 0..2
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey DescribeConfigs (32) Versions 0..4
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey AlterConfigs (33) Versions 0..2
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey AlterReplicaLogDirs (34) Versions 0..2
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey DescribeLogDirs (35) Versions 0..2
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey SaslAuthenticate (36) Versions 0..2
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey CreatePartitions (37) Versions 0..3
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey CreateDelegationToken (38) Versions 0..2
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey RenewDelegationToken (39) Versions 0..2
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey ExpireDelegationToken (40) Versions 0..2
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey DescribeDelegationToken (41) Versions 0..2
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey DeleteGroups (42) Versions 0..2
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey ElectLeadersRequest (43) Versions 0..2
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey IncrementalAlterConfigsRequest (44) Versions 0..1
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey AlterPartitionReassignmentsRequest (45) Versions 0..0
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey ListPartitionReassignmentsRequest (46) Versions 0..0
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey OffsetDeleteRequest (47) Versions 0..0
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey DescribeClientQuotasRequest (48) Versions 0..1
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey AlterClientQuotasRequest (49) Versions 0..1
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey DescribeUserScramCredentialsRequest (50) Versions 0..0
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey AlterUserScramCredentialsRequest (51) Versions 0..0
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey AlterIsrRequest (56) Versions 0..0
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey UpdateFeaturesRequest (57) Versions 0..0
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey Unknown-60? (60) Versions 0..0
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:   ApiKey Unknown-61? (61) Versions 0..0
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature MsgVer1: Produce (2..2) supported by broker
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature MsgVer1: Fetch (2..2) supported by broker
%7|1633540193.854|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Enabling feature MsgVer1
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature MsgVer2: Produce (3..3) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature MsgVer2: Fetch (4..4) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Enabling feature MsgVer2
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature ApiVersion: ApiVersion (0..0) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Enabling feature ApiVersion
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Enabling feature BrokerGroupCoordinator
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Enabling feature BrokerBalancedConsumer
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature ThrottleTime: Produce (1..2) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature ThrottleTime: Fetch (1..2) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Enabling feature ThrottleTime
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature Sasl: JoinGroup (0..0) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Enabling feature Sasl
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature SaslHandshake: SaslHandshake (0..0) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Enabling feature SaslHandshake
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature LZ4: FindCoordinator (0..0) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Enabling feature LZ4
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature OffsetTime: Offset (1..1) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Enabling feature OffsetTime
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature IdempotentProducer: InitProducerId (0..0) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Enabling feature IdempotentProducer
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature ZSTD: Produce (7..7) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature ZSTD: Fetch (10..10) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Enabling feature ZSTD
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature SaslAuthReq: SaslHandshake (1..1) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap:  Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker
%7|1633540193.855|APIVERSION|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Enabling feature SaslAuthReq
%7|1633540193.855|FEATURE|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq
%7|1633540193.855|STATE|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Broker changed state APIVERSION_QUERY -> UP
%7|1633540193.855|BROADCAST|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: Broadcasting state change
%7|1633540193.855|METADATA|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Request metadata for brokers only: connected
%7|1633540193.855|SEND|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Sent MetadataRequest (v4, 26 bytes @ 0, CorrId 2)
%7|1633540193.856|METADATA|rdkafka#producer-1| [thrd:app]: kafka:9092/bootstrap: Request metadata for all topics: application requested
%7|1633540193.856|SEND|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Sent MetadataRequest (v4, 26 bytes @ 0, CorrId 3)
%7|1633540193.867|RECV|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: Received MetadataResponse (v4, 57 bytes, CorrId 2, rtt 12.30ms)
%7|1633540193.867|METADATA|rdkafka#producer-1| [thrd:main]: kafka:9092/bootstrap: ===== Received metadata: connected =====
%7|1633540193.867|METADATA|rdkafka#producer-1| [thrd:main]: kafka:9092/bootstrap: ClusterId: MFG1M9J5QXGuTLknc5gq-w, ControllerId: 0
%7|1633540193.867|METADATA|rdkafka#producer-1| [thrd:main]: kafka:9092/bootstrap: 1 brokers, 0 topics
%7|1633540193.867|METADATA|rdkafka#producer-1| [thrd:main]: kafka:9092/bootstrap:   Broker #0/1: kafka:9092 NodeId 0
%7|1633540193.867|CLUSTERID|rdkafka#producer-1| [thrd:main]: kafka:9092/bootstrap: ClusterId update "" -> "MFG1M9J5QXGuTLknc5gq-w"
%7|1633540193.867|CONTROLLERID|rdkafka#producer-1| [thrd:main]: kafka:9092/bootstrap: ControllerId update -1 -> 0
%7|1633540193.867|BROADCAST|rdkafka#producer-1| [thrd:main]: Broadcasting state change
%7|1633540193.867|UPDATE|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/bootstrap: NodeId changed from -1 to 0
%7|1633540193.868|UPDATE|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/0: Name changed from kafka:9092/bootstrap to kafka:9092/0
%7|1633540193.868|LEADER|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/0: Mapped 0 partition(s) to broker
%7|1633540193.868|STATE|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/0: Broker changed state UP -> UPDATE
%7|1633540193.868|BROADCAST|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: Broadcasting state change
%7|1633540193.868|BROADCAST|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: Broadcasting state change
%7|1633540193.868|STATE|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/0: Broker changed state UPDATE -> UP
%7|1633540193.868|BROADCAST|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: Broadcasting state change
%7|1633540193.870|RECV|rdkafka#producer-1| [thrd:kafka:9092/bootstrap]: kafka:9092/0: Received MetadataResponse (v4, 57 bytes, CorrId 3, rtt 13.90ms)
%7|1633540193.870|METADATA|rdkafka#producer-1| [thrd:main]: kafka:9092/0: ===== Received metadata: application requested =====
%7|1633540193.870|METADATA|rdkafka#producer-1| [thrd:main]: kafka:9092/0: ClusterId: MFG1M9J5QXGuTLknc5gq-w, ControllerId: 0
%7|1633540193.870|METADATA|rdkafka#producer-1| [thrd:main]: kafka:9092/0: 1 brokers, 0 topics
%7|1633540193.870|METADATA|rdkafka#producer-1| [thrd:main]: kafka:9092/0:   Broker #0/1: kafka:9092 NodeId 0
%7|1633540193.870|METADATA|rdkafka#producer-1| [thrd:main]: Absolute update of metadata cache with 0 topic(s)
%7|1633540193.870|METADATA|rdkafka#producer-1| [thrd:main]: kafka:9092/0: Caching full metadata with 1 broker(s) and 0 topic(s): application requested
%7|1633540193.877|TOPIC|rdkafka#producer-1| [thrd:app]: New local topic: test
%7|1633540193.877|TOPPARNEW|rdkafka#producer-1| [thrd:app]: NEW test [-1] 0xaaaae0c6f0c0 refcnt 0xaaaae0c6f150 (at rd_kafka_topic_new0:465)
%7|1633540193.877|METADATA|rdkafka#producer-1| [thrd:app]: Hinted cache of 1/1 topic(s) being queried
%7|1633540193.877|METADATA|rdkafka#producer-1| [thrd:app]: Requesting metadata for 1/1 topics: leader query
%7|1633540193.877|METADATA|rdkafka#producer-1| [thrd:app]: kafka:9092/0: Request metadata for 1 topic(s): leader query