上接前一篇 Kafka入门 ,里面提到启动Kafka以及使用一些Kafka bin 目录下的脚本的时候,需要用到 zookeeper,所以这里简单提一句zookeeper相关的注意事项。
zookeeper 是Google开源的一个为分布式应用提供一致性服务的分布式软件,它是大数据环境下的一个重要组件。它提供了包括配置维护、域名服务、分布式同步、组服务在内的多项功能。
zookeeper 的核心存储是类似于Unix文件系统的命名空间,所以在使用的时候,需要注意它的“文件路径”。
比如新建Kafka topic的时候,需要指定的 zookeeper参数里,需要带上路径:
./bin/kafka-topics.sh --zookeeper 172.16.1.33:2181,172.16.1.34:2181,172.16.1.35:2181/kafka-test
而这个路径,往往也会在启动Kafka必须带上的配置文件 server.properties 里指定
[admin@host kafka-current]$ cat config/server.properties | grep zookeeper
...
zookeeper.connect=172.16.1.33:2181,172.16.1.34:2181,172.16.1.35:2181/kafka-test
...
更多的 zookeeper 请参考官网 Apache zookeeper
网友评论