我在aws有一个合流的oss设置，有三个经纪人，三个Zookeeper和两个工人。在其中一个worker中配置server.properties时，我被 listeners 以及 advertised.listeners 属性。
我搜索了解决方案，并建议在任何地方设置 listeners 以及 advertised.listeners . 我尝试了以下属性：

listeners=PLAINTEXT://localhost:9092
advertised.listeners=PLAINTEXT://<public-ip-of-worker>:9092

也尝试过：

listeners=PLAINTEXT://0.0.0.0:9092

通过上述设置，问题：
kafka connect服务器出现以下错误：

[2019-07-17 13:03:19,067] WARN [Consumer clientId=consumer-2, groupId=connect-cluster] Error while fetching metadata with correlation id 9781 : {connect-statuses=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient:968)
    [2019-07-17 13:03:19,170] WARN [Consumer clientId=consumer-2, groupId=connect-cluster] Error while fetching metadata with correlation id 9782 : {connect-statuses=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient:968)

每当我们尝试使用ksql创建/删除一个主题时，就会出现以下错误：

[2019-07-17 12:53:08,351] WARN Timeout to get commandStatus, waited 5000 milliseconds:, statementText:TERMINATE CSAS_YP_SINK_TOPIC_38; (io.confluent.ksql.rest.server.resources.KsqlResource:375)
java.util.concurrent.TimeoutException
    at io.confluent.ksql.rest.server.computation.CommandStatusFuture.get(CommandStatusFuture.java:76)
    at io.confluent.ksql.rest.server.computation.CommandStatusFuture.get(CommandStatusFuture.java:29)
    at io.confluent.ksql.rest.server.resources.KsqlResource.distributeStatement(KsqlResource.java:373)
    at io.confluent.ksql.rest.server.resources.KsqlResource.executeStatement(KsqlResource.java:334)
    at io.confluent.ksql.rest.server.resources.KsqlResource.handleKsqlStatements(KsqlResource.java:200)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

所以现在，我对 server.properties 为我们的集群配置，是将workers ip用于侦听器还是代理ip。如果是brokers ip，则我们有三个brokers，并且无法将所有brokers设置为同一端口？
如有任何建议，我们将不胜感激。
共享我的connect和ksql属性：
反对的论点necthttps://www.writeurl.com/publish/15z9zu3j5k5jxim1k81d
ksqlhttps://www.writeurl.com/publish/uvtlxgbld369hpahozju