You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Configure a Producer or Consumer with a list of brokers where the first broker in the list cannot be reached (hostname is invalid, host is down, wrong port, ect) but there are valid, alive brokers in metadata.broker.list. Request metadata using prod->metadata(...). The Local: Timed out or Local: Broker transport failure error code will be returned.
How to reproduce
Start a kafka cluster with a node on localhost:9092.
run ./rdkafka_example_cpp -L -d all -b "google.com:9092,localhost:9092"
any hostname that doesn't have kafka running on port 9092 in the above example works.
Checklist
Please provide the following information:
[x ] librdkafka version (release number or git tag):0.9.1
[x ] Apache Kafka version: 0.9.0.0
librdkafka client configuration:
[x ] Operating system: Ubuntu 16.04
Using the legacy Consumer
Using the high-level KafkaConsumer
[x ] Provide logs (with debug=.. as necessary) from librdkafka
Log for ./rdkafka_example_cpp -L -d all -b "google.com:9092,localhost:9092": log
Log for ./rdkafka_example_cpp -L -d all -b "localhost:9090,localhost:9092"log2
Provide broker log excerpts
[x ] Critical issue
The text was updated successfully, but these errors were encountered:
Description
Configure a Producer or Consumer with a list of brokers where the first broker in the list cannot be reached (hostname is invalid, host is down, wrong port, ect) but there are valid, alive brokers in metadata.broker.list. Request metadata using prod->metadata(...). The
Local: Timed out
orLocal: Broker transport failure
error code will be returned.How to reproduce
Start a kafka cluster with a node on localhost:9092.
run
./rdkafka_example_cpp -L -d all -b "google.com:9092,localhost:9092"
any hostname that doesn't have kafka running on port 9092 in the above example works.
Checklist
Please provide the following information:
debug=..
as necessary) from librdkafkaLog for
./rdkafka_example_cpp -L -d all -b "google.com:9092,localhost:9092"
: logLog for
./rdkafka_example_cpp -L -d all -b "localhost:9090,localhost:9092"
log2The text was updated successfully, but these errors were encountered: