kavka：在连接AWS msk代理时，客户端用尽了可用的代理，无法与之对话您的群集是否可以访问？

问题描述

我在eks（amazon k8）集群上使用Sharma go客户端连接AWS MSK，我正在使用以下代码

    config := Sarama.NewConfig()
    config.Consumer.Return.Errors = true
    kafkaClient,err = Sarama.NewClient(brokerAddress,config)

brokerAddress is an array of string value is [http://kafka-broker-url-1:9092,http://kafka-broker-url-2:9092]

I am getting an error 
Kafka: the client has run out of available brokers to talk to (Is your cluster reachable?)

I also tried below code snippet to connect but got the same error:

    admin,err := Sarama.NewClusteradmin(brokerAddress,config)
    if err != nil {
        KafkaLogger.Info("Error while creating cluster admin: ",err.Error())
    }

Is there any config setting which I am missing?

In the same container(to verify cluster),I tried to create a topic using Kafka script and was able to connect via zookeeper[i used a script which is present inside the bin folder,https://downloads.apache.org/kafka/2.2.2/kafka_2.11-2.2.2.tgz]

./kafka-topics.sh --create --zookeeper z-kafka.us-west-2.amazonaws.com:2181 --replication-factor 1 --partitions 1 --topic Test

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）