配置Apache Kafka的Zookeeper配置文件zookeeper.propertie

本人使用Apache Kafka的版本是0.7.2,Kafka默认的zookeeper.properties文件如下所示:

配置Apache Kafka的Zookeeper配置文件zookeeper.propertie

dataDir,clientPort的意义显而易见,就不用说了,对于maxClientCnxns选项,如果不设置或者设置为0,则每个ip连接zookeeper时的连接数没有限制。需要注意的是,设置maxClientCnxns的值时需要把kafka server的连接数考虑进去,因为启动kafka server时,kafka server也会连接zookeeper的。

例如,我把机器a的zookeeper.properties按下图所示来设置,其中maxClientCnxns=1

配置Apache Kafka的Zookeeper配置文件zookeeper.propertie

首先启动zookeeper,接着还是在机器a启动kafka server,server.properties的enable.zookeeper=true,如下图所示,kafka server也启动成功了

配置Apache Kafka的Zookeeper配置文件zookeeper.propertie

接下来在机器a启动Producer,如下面两幅图所示,重连多次都失败了

配置Apache Kafka的Zookeeper配置文件zookeeper.propertie

而zookeeper在标准输出提示我们超过配置文件里所设置的连接数了

配置Apache Kafka的Zookeeper配置文件zookeeper.propertie

因为我们设置maxClientCnxns=1,kafka server在机器a启动成功后,机器a连接zookeeper的连接数就是1了,如果接着在机器a启动producer,连接数就变成2了,超过maxClientCnxns的值,所以producer连接不上zookeeper.

分布式发布订阅消息系统 Kafka 架构设计

Apache Kafka 代码实例

Apache Kafka 教程笔记

Kafka使用入门教程

Kafka 的详细介绍请点这里
Kafka 的下载地址请点这里

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/acc3884ebc9e1c372984f9445fb3d73d.html