confluentinc / librdkafka

The Apache Kafka C/C++ library

Other

214 stars 3.14k forks source link

rd_kafka_clustid does not return until timeout when kafka has no topic #3620

Open kenlee1988 opened 2 years ago

kenlee1988 commented 2 years ago

Read the FAQ first: https://github.com/edenhill/librdkafka/wiki/FAQ

Do NOT create issues for questions, use the discussion forum: https://github.com/edenhill/librdkafka/discussions

Description

rd_kafka_clustid does not return until timeout when kafka has no topic

How to reproduce

when kafka has no topic，rd_kafka_clustid does not return until timeout

IMPORTANT: Always try to reproduce the issue on the latest released version (see https://github.com/edenhill/librdkafka/releases), if it can't be reproduced on the latest version the issue has been fixed.

Checklist

IMPORTANT: We will close issues where the checklist has not been completed.

Please provide the following information:

[x] librdkafka version (release number or git tag): 1.8.2
[x] Apache Kafka version: 2.3.1
[ ] librdkafka client configuration: <REPLACE with e.g., message.timeout.ms=123, auto.reset.offset=earliest, ..>
[ ] Operating system: <REPLACE with e.g., Centos 5 (x64)>
[ ] Provide logs (with debug=.. as necessary) from librdkafka
[ ] Provide broker log excerpts
[ ] Critical issue

edenhill commented 2 years ago

Can you repro this with debug=all and provide the logs?

kenlee1988 commented 2 years ago

%7|1637217029.626|WAKEUPFD|rdkafka#producer-1| [thrd:app]: 10.4.98.158:31100/bootstrap: Enabled low-latency ops queue wake-ups %7|1637217029.627|BROKER|rdkafka#producer-1| [thrd:app]: 10.4.98.158:31100/bootstrap: Added new broker with NodeId -1 %7|1637217029.627|CONNECT|rdkafka#producer-1| [thrd:app]: 10.4.98.158:31100/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s)) %7|1637217029.627|BRKMAIN|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Enter main broker thread %7|1637217029.627|BRKMAIN|rdkafka#producer-1| [thrd::0/internal]: :0/internal: Enter main broker thread %7|1637217029.627|INIT|rdkafka#producer-1| [thrd:app]: librdkafka v1.8.2-devel (0x10802ff) rdkafka#producer-1 initialized (builtin.features snappy,ssl,sasl,regex,lz4,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer, STATIC_LINKING GCC GXX PKGCONFIG INSTALL GNULD LDS LIBDL PLUGINS SSL ZSTD HDRHISTOGRAM SYSLOG SNAPPY SOCKEM SASL_SCRAM SASL_OAUTHBEARER CRC32C_HW, debug 0xfffff) %7|1637217029.627|CONF|rdkafka#producer-1| [thrd:app]: Client configuration: %7|1637217029.627|CONF|rdkafka#producer-1| [thrd:app]: client.software.name = confluent-kafka-go %7|1637217029.627|CONF|rdkafka#producer-1| [thrd:app]: client.software.version = 1.8.2-devel %7|1637217029.627|CONF|rdkafka#producer-1| [thrd:app]: metadata.broker.list = 10.4.98.158:31100 %7|1637217029.627|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|1637217029.627|CONF|rdkafka#producer-1| [thrd:app]: enabled_events = 328 %7|1637217029.627|CONNECT|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Received CONNECT op %7|1637217029.627|STATE|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Broker changed state INIT -> TRY_CONNECT %7|1637217029.627|BROADCAST|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: Broadcasting state change %7|1637217029.627|CONNECT|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: broker in state TRY_CONNECT connecting %7|1637217029.627|STATE|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Broker changed state TRY_CONNECT -> CONNECT %7|1637217029.627|BROADCAST|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: Broadcasting state change %7|1637217029.627|CONNECT|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Connecting to ipv4#10.4.98.158:31100 (plaintext) with socket 17 %7|1637217029.628|CONNECT|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Connected to ipv4#10.4.98.158:31100 %7|1637217029.628|CONNECTED|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Connected (#1) %7|1637217029.628|FEATURE|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Updated enabled protocol features +ApiVersion to ApiVersion %7|1637217029.628|STATE|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Broker changed state CONNECT -> APIVERSION_QUERY %7|1637217029.628|BROADCAST|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: Broadcasting state change %7|1637217029.628|SEND|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Sent ApiVersionRequest (v3, 54 bytes @ 0, CorrId 1) %7|1637217029.632|RECV|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Received ApiVersionResponse (v3, 6 bytes, CorrId 1, rtt 4.07ms) %7|1637217029.632|PROTOERR|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Protocol parse failure for ApiVersion v3(flex) at 3/6 (rd_kafka_handle_ApiVersion:2131) (incorrect broker.version.fallback?) %7|1637217029.632|PROTOERR|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiArrayCnt -1 out of range %7|1637217029.632|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiVersionRequest v3 failed due to UNSUPPORTED_VERSION: retrying with v0 %7|1637217029.632|SEND|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Sent ApiVersionRequest (v0, 21 bytes @ 0, CorrId 2) %7|1637217029.634|RECV|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Received ApiVersionResponse (v0, 276 bytes, CorrId 2, rtt 1.44ms) %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Broker API support: %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey Produce (0) Versions 0..7 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey Fetch (1) Versions 0..11 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey ListOffsets (2) Versions 0..5 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey Metadata (3) Versions 0..8 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey LeaderAndIsr (4) Versions 0..2 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey StopReplica (5) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey UpdateMetadata (6) Versions 0..5 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey ControlledShutdown (7) Versions 0..2 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey OffsetCommit (8) Versions 0..7 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey OffsetFetch (9) Versions 0..5 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey FindCoordinator (10) Versions 0..2 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey JoinGroup (11) Versions 0..5 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey Heartbeat (12) Versions 0..3 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey LeaveGroup (13) Versions 0..2 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey SyncGroup (14) Versions 0..3 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey DescribeGroups (15) Versions 0..3 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey ListGroups (16) Versions 0..2 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey SaslHandshake (17) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey ApiVersion (18) Versions 0..2 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey CreateTopics (19) Versions 0..3 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey DeleteTopics (20) Versions 0..3 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey DeleteRecords (21) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey InitProducerId (22) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey OffsetForLeaderEpoch (23) Versions 0..3 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey AddPartitionsToTxn (24) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey AddOffsetsToTxn (25) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey EndTxn (26) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey WriteTxnMarkers (27) Versions 0..0 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey TxnOffsetCommit (28) Versions 0..2 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey DescribeAcls (29) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey CreateAcls (30) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey DeleteAcls (31) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey DescribeConfigs (32) Versions 0..2 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey AlterConfigs (33) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey AlterReplicaLogDirs (34) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey DescribeLogDirs (35) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey SaslAuthenticate (36) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey CreatePartitions (37) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey CreateDelegationToken (38) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey RenewDelegationToken (39) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey ExpireDelegationToken (40) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey DescribeDelegationToken (41) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey DeleteGroups (42) Versions 0..1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey ElectLeadersRequest (43) Versions 0..0 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: ApiKey IncrementalAlterConfigsRequest (44) Versions 0..0 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature MsgVer1: Produce (2..2) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature MsgVer1: Fetch (2..2) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Enabling feature MsgVer1 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature MsgVer2: Produce (3..3) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature MsgVer2: Fetch (4..4) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Enabling feature MsgVer2 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature ApiVersion: ApiVersion (0..0) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Enabling feature ApiVersion %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature BrokerGroupCoordinator: FindCoordinator (0..0) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Enabling feature BrokerGroupCoordinator %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature BrokerBalancedConsumer: FindCoordinator (0..0) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature BrokerBalancedConsumer: OffsetCommit (1..2) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature BrokerBalancedConsumer: OffsetFetch (1..1) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature BrokerBalancedConsumer: JoinGroup (0..0) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature BrokerBalancedConsumer: SyncGroup (0..0) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature BrokerBalancedConsumer: Heartbeat (0..0) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature BrokerBalancedConsumer: LeaveGroup (0..0) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Enabling feature BrokerBalancedConsumer %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature ThrottleTime: Produce (1..2) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature ThrottleTime: Fetch (1..2) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Enabling feature ThrottleTime %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature Sasl: JoinGroup (0..0) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Enabling feature Sasl %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature SaslHandshake: SaslHandshake (0..0) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Enabling feature SaslHandshake %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature LZ4: FindCoordinator (0..0) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Enabling feature LZ4 %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature OffsetTime: ListOffsets (1..1) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Enabling feature OffsetTime %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature IdempotentProducer: InitProducerId (0..0) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Enabling feature IdempotentProducer %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature ZSTD: Produce (7..7) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature ZSTD: Fetch (10..10) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Enabling feature ZSTD %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature SaslAuthReq: SaslHandshake (1..1) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Feature SaslAuthReq: SaslAuthenticate (0..0) supported by broker %7|1637217029.634|APIVERSION|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Enabling feature SaslAuthReq %7|1637217029.634|FEATURE|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Updated enabled protocol features to MsgVer1,ApiVersion,BrokerBalancedConsumer,ThrottleTime,Sasl,SaslHandshake,BrokerGroupCoordinator,LZ4,OffsetTime,MsgVer2,IdempotentProducer,ZSTD,SaslAuthReq %7|1637217029.634|STATE|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Broker changed state APIVERSION_QUERY -> UP %7|1637217029.634|BROADCAST|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: Broadcasting state change %7|1637217029.634|METADATA|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Request metadata for brokers only: connected %7|1637217029.634|SEND|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Sent MetadataRequest (v4, 26 bytes @ 0, CorrId 3) %7|1637217029.637|RECV|rdkafka#producer-1| [thrd:10.4.98.158:31100/bootstrap]: 10.4.98.158:31100/bootstrap: Received MetadataResponse (v4, 109 bytes, CorrId 3, rtt 2.35ms) %7|1637217029.637|METADATA|rdkafka#producer-1| [thrd:main]: 10.4.98.158:31100/bootstrap: ===== Received metadata: connected ===== %7|1637217029.637|METADATA|rdkafka#producer-1| [thrd:main]: 10.4.98.158:31100/bootstrap: ClusterId: isYWmBEaS3ClkPsVxeC5bA, ControllerId: 1001 %7|1637217029.637|METADATA|rdkafka#producer-1| [thrd:main]: 10.4.98.158:31100/bootstrap: 3 brokers, 0 topics %7|1637217029.637|METADATA|rdkafka#producer-1| [thrd:main]: 10.4.98.158:31100/bootstrap: Broker #0/3: 10.4.98.158:31101 NodeId 1001 %7|1637217029.637|WAKEUPFD|rdkafka#producer-1| [thrd:main]: 10.4.98.158:31101/1001: Enabled low-latency ops queue wake-ups %7|1637217029.637|BROKER|rdkafka#producer-1| [thrd:main]: 10.4.98.158:31101/1001: Added new broker with NodeId 1001 %7|1637217029.637|METADATA|rdkafka#producer-1| [thrd:main]: 10.4.98.158:31100/bootstrap: Broker #1/3: 10.4.98.144:31100 NodeId 1003 %7|1637217029.637|BRKMAIN|rdkafka#producer-1| [thrd:10.4.98.158:31101/1001]: 10.4.98.158:31101/1001: Enter main broker thread %7|1637217029.637|WAKEUPFD|rdkafka#producer-1| [thrd:main]: 10.4.98.144:31100/1003: Enabled low-latency ops queue wake-ups %7|1637217029.638|BROKER|rdkafka#producer-1| [thrd:main]: 10.4.98.144:31100/1003: Added new broker with NodeId 1003 %7|1637217029.638|METADATA|rdkafka#producer-1| [thrd:main]: 10.4.98.158:31100/bootstrap: Broker #2/3: 10.4.98.159:31102 NodeId 1002 %7|1637217029.638|BRKMAIN|rdkafka#producer-1| [thrd:10.4.98.144:31100/1003]: 10.4.98.144:31100/1003: Enter main broker thread %7|1637217029.638|WAKEUPFD|rdkafka#producer-1| [thrd:main]: 10.4.98.159:31102/1002: Enabled low-latency ops queue wake-ups %7|1637217029.638|BROKER|rdkafka#producer-1| [thrd:main]: 10.4.98.159:31102/1002: Added new broker with NodeId 1002 %7|1637217029.638|CLUSTERID|rdkafka#producer-1| [thrd:main]: 10.4.98.158:31100/bootstrap: ClusterId update "" -> "isYWmBEaS3ClkPsVxeC5bA" %7|1637217029.638|CONTROLLERID|rdkafka#producer-1| [thrd:main]: 10.4.98.158:31100/bootstrap: ControllerId update -1 -> 1001 %7|1637217029.638|BROADCAST|rdkafka#producer-1| [thrd:main]: Broadcasting state change %7|1637217029.638|BRKMAIN|rdkafka#producer-1| [thrd:10.4.98.159:31102/1002]: 10.4.98.159:31102/1002: Enter main broker thread %7|1637217049.626|CACHEWAIT|rdkafka#producer-1| [thrd:app]: rd_kafka_metadata_cache_wait_change wait took 19999ms: timed out

edenhill commented 2 years ago

Thanks! PR is under review

anchitj commented 2 months ago

Closing as the fix is merged. Feel free to reopen if the issue still occurs.