kafka配置项host.name advertised.host.name

遇到的问题：

在本机或者其他机器telnet IP 9092，通，使用域名也通，telnet 127.0.0.1 9092不通

host.name：按配置文件说明，是Kafka绑定的interface。其实这个说明有点误导，下面会见到。

advertised.host.name：是注册到zookeeper，client要访问的broker地址。（可能producer也是拿这个值，没有验证）

如果advertised.host.name没有设，会用host.name的值注册到zookeeper，如果host.name也没有设，则会使用JVM拿到的本机hostname注册到zk。

这里有两个坑要注意：

如果advertised.host.name没有设，host.name不能设为0.0.0.0，否则client通过zk拿到的broker地址就是0.0.0.0。
如果指定要bind到所有interface，host.name不设就可以。
如果host.name和advertised.host.name都不设，client通过zk拿到的就是JVM返回的本机hostname，如果这个hostname是client无法访问到的，client就会连不上broker。
所以如果要bind到所有interface，client又能访问，解决的办法是host.name不设或设置0.0.0.0，advertised.host.name一定要设置为一个client可以访问的地址，如直接设IP地址。
如果不需要bind到所有interface，也可以只在host.name设置IP地址。

简单的检查broker是否可以被client访问到的办法，就是在zookeeper中看broker信息，上面显示的hostname是否是client可以访问到的地址。
在zkCli中执行get /brokers/<id>

advertised.listeners=PLAINTEXT://docp1:9092 设了这个值就不用advertised.host.name 和 host.name选项了

转载于:https://www.cnblogs.com/sunshine-long/p/10772406.html

kafka配置项host.name advertised.host.name相关推荐

SAP Cloud Connector里的virtual host和internal host有什么区别
在创建系统映射时,我遇到了下面的两组字段:virtual host和internet host. Virtual host可以按照需要填写成任何human readable的名称,而internal ...
.NET Core 的Generic Host 之Generic Host Builder
通用Host(Generic Host) 与 web Host 不同的地方就是通用Host解耦了Http请求管道,使得通用Host拥有更广的应用场景.比如:消息收发.后台任务以及其他非http的工作负 ...
【kafka】kerberos认证下 kafka 报错Bootstrap broker host:ip (id: -1 rack: null) disconnected
文章目录 1.概述 1.概述本博文中的IP都是随便写的. 公司整了一个新的环境,然后我要进行适配,结果发现对方有认证,无法直接使用,使用控制台生产和消费的时候报错. [domain_realm][r ...
Flink】Flink连接prometheus 端口报错 Invalid host/port configuration. Host xxx Port -1
1.美图 2.背景本地运行flink,然后连接本地的prometheus端口正确,但是运行总是报错 conf.setString("metrics.reporter.promgateway ...
html设置网页host,HTML Anchor host用法及代码示例
HTML DOM中的DOM Anchor主机属性用于设置或返回主机名,并发布href属性值的一部分. 用法: 它返回主机属性.anchorObject.host 用于设置主机属性.anchorObje ...
nginx配置中$http_host、$host、$host:$proxy_port和$host:$server_port区别
1.proxy_set_header设置的请求头是传递给后端服务器的 ngixn反向代理中proxy_set_header的设置: proxy_set_header Host $http_host;p ...
kafka集群的搭建
本系列文章主要阐述大数据计算平台相关框架的搭建,包括如下内容: 基础环境安装 zookeeper集群的搭建 kafka集群的搭建 hadoop/hbase集群的搭建 spark集群的搭建 flink集 ...
linux server.xml日志参数,Linux Log4j+Kafka+KafkaLog4jAppender 日志收集
背景: kafka版本:kafka_2.10-0.8.2.1 服务器IP:10.243.3.17 一:Kafkaserver.properties 文件配置二:zookeeper.propertie ...
使用filbeat从kafka中消费json格式日志并发送到ElasticSearch
环境 filbeat 7.10 kafka 2.1 elasticsearch 7.4.2 windows 10 需求描述 Java程序生产Json格式的日志发送到kafka中,再由filebeat从 ...
SPRINGBOOT项目连接远程服务器上KAFKA遇到的坑以及完整的例子
版本 springboot 2.1.5.RELEASE kafka 2.2 遇到的坑用最新的springboot就要用最新的kafka版本! 当我启动云服务器上的zk后,再启动kafka后台日志也没 ...

kafka配置项host.name advertised.host.name

kafka配置项host.name advertised.host.name相关推荐

最新文章

热门文章