librdkafka
librdkafka copied to clipboard
query_watermark_offsets() Doesn't Return Authentication Failure Errors.
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
- [x] librdkafka version (release number or git tag):
1.9.2 - [x] Apache Kafka version:
3.2.0 - [x] librdkafka client configuration:
sasl.mechanism=scram-sha-512, security.protocol=sasl_ssl - [x] Operating system:
Red Hat Enterprise Linux 8.8 - [ ] Provide logs (with
debug=..as necessary) from librdkafka - [ ] Provide broker log excerpts
- [ ] Critical issue