kafka的配置:
broker.id=0 #端口号 port=9092 #单机可直接用localhost host.name=localhost #日志存放路径可修改可不修改 log.dirs=/usr/local/kafka/kafka_2.13-2.8.0/log #zookeeper地址和端口,单机配置部署,localhost:2181 zookeeper.connect=localhost:2181 #配置后外部其他机器可以访问 listeners=PLAINTEXT://:9092 advertised.listeners=PLAINTEXT://42.192.41.114:9092 (42.192.41.114:为公网ip)
要对其listeners和advertised.listeners配置,才能远程调用api: listeners 是kafka真正bind的地址 advertised.listeners 是暴露给外部的listeners,如果没有设置,会用listeners
listeners listeners就是主要用来定义Kafka Broker的Listener的配置项。 advertised.listeners advertised.listeners参数的作用就是将Broker的Listener信息发布到Zookeeper中
kafka对这两个参数的说明: listeners=PLAINTEXT://: 定义kafka的服务监听地址,addr可以为空,或者0.0.0.0,表示kafka服务会监听在指定地址。
advertised.listeners: kafka发布到zookeeper供客户端使用的服务地址,格式也是PLAINTEXT://:,但是addr不能为空。 如果KAFKA_ADVERTISED_LISTENERS没有定义,则是取的KAFKA_LISTENERS的值。 如果KAFKA_LISTENERS的addr没有定义,则取的java.net.InetAddress.getCanonicalHostName()值。
作者:CodingCode 链接:https://www.jianshu.com/p/26495e334613 来源:简书 著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。
|