When the authentication password is incorrect query_watermark_offsets() returns "All broker connections are down" error instead of an authentication failed error.
Also noticed that, rd_kafka_topic_partition_list_query_leaders()function has below validation to return above "All broker connections are down" error when using query_watermark_offsets method.
if (rd_atomic32_get(&rk->rk_broker_up_cnt) == 0) return RD_KAFKA_RESP_ERR__ALL_BROKERS_DOWN;
How to reproduce
Try to query the watermark offsets after configuring sasl.password to incorrect one.
Checklist
[x] librdkafka version (release number or git tag): 1.9.2
Description
When the authentication password is incorrect
query_watermark_offsets()returns "All broker connections are down" error instead of an authentication failed error.Also noticed that,
rd_kafka_topic_partition_list_query_leaders()function has below validation to return above "All broker connections are down" error when using query_watermark_offsets method.if (rd_atomic32_get(&rk->rk_broker_up_cnt) == 0) return RD_KAFKA_RESP_ERR__ALL_BROKERS_DOWN;How to reproduce
Try to query the watermark offsets after configuring sasl.password to incorrect one.
Checklist
1.9.23.2.0sasl.mechanism=scram-sha-512, security.protocol=sasl_sslRed Hat Enterprise Linux 8.8debug=..as necessary) from librdkafka