Linux下Kafka集群环境搭建(2)

#进入到Zookeeper的bin目录下 #server1 cd /opt/zookeeper/server1/zookeeper-3.4.10/bin #启动服务 ./zkServer.sh start #server2 cd /opt/zookeeper/server2/zookeeper-3.4.10/bin #启动服务 ./zkServer.sh start #server3 cd /opt/zookeeper/server3/zookeeper-3.4.10/bin #启动服务 ./zkServer.sh start #启动成功后的信息(server1为例): ZooKeeper JMX enabled by default Using config: /opt/zookeeper/server1/zookeeper-3.4.10/bin/../conf/zoo.cfg Starting zookeeper ... STARTED

2,检查服务状态

#检查服务器状态 ./zkServer.sh status

 

#下面的状态为启动成功。 ZooKeeper JMX enabled by default Using config: /home/user/zookeeper/server3/zookeeper3.4.10/bin/../conf/zoo.cfg Mode: follower
#Mode有两种类型:leader和follower,leader代表领导(主节点),follower代表下属(备节点)
#zk集群一般只有一个leader,多个follower,主一般是相应客户端的读写请求,而从主同步数据,当主挂掉之后就会从follower里投票选举一个leader出来。

至此,zookeeper集群就成功搭建完成了,接下来我们开始搭建kafka。

配置&安装Kafka

#创建目录 cd /opt/ mkdir kafka #创建项目目录 cd kafka
mkdir kafkalogs #创建kafka消息目录,主要存放kafka消息-对应server1服务器
mkdir kafkalogs1 #创建kafka消息目录,主要存放kafka消息-对应server2服务器 mkdir kafkalogs2 #创建kafka消息目录,主要存放kafka消息-对应server3服务器
#解压kafka_2.11-1.0.0.tgz到kafka目录下

tar -zxvf
kafka_2.11-1.0.0.tgz #如果是三台真实的linux服务器,只需要将kafka_2.11-1.0.0.tgz解压到三台服务器的/opt/kafka目录下,再新建kafkalogs即可。

修改kafka配置文件

#进入到config目录 cd /opt/kafka/kafka_2.11-1.0.0/config/

我们可以看到目录下有zookeeper的一些文件,这是kafka内置的zookeeper集群,我们可以使用它来直接启动,但建议使用独立的zookeeper集群。

-rw-r--r--. 1 root root 906 Oct 27 08:56 connect-console-sink.properties -rw-r--r--. 1 root root 909 Oct 27 08:56 connect-console-source.properties -rw-r--r--. 1 root root 5807 Oct 27 08:56 connect-distributed.properties -rw-r--r--. 1 root root 883 Oct 27 08:56 connect-file-sink.properties -rw-r--r--. 1 root root 881 Oct 27 08:56 connect-file-source.properties -rw-r--r--. 1 root root 1111 Oct 27 08:56 connect-log4j.properties -rw-r--r--. 1 root root 2730 Oct 27 08:56 connect-standalone.properties -rw-r--r--. 1 root root 1221 Oct 27 08:56 consumer.properties -rw-r--r--. 1 root root 4727 Oct 27 08:56 log4j.properties -rw-r--r--. 1 root root 1919 Oct 27 08:56 producer.properties -rw-r--r--. 1 root root 173 Jan 7 05:54 server-1.properties -rw-r--r--. 1 root root 173 Jan 7 05:56 server-2.properties -rw-r--r--. 1 root root 172 Jan 7 05:55 server.properties -rw-r--r--. 1 root root 1032 Oct 27 08:56 tools-log4j.properties -rw-r--r--. 1 root root 1023 Oct 27 08:56 zookeeper.properties

我们主要修改 server.properties 这个文件即可. 用以下代码覆盖server.properties里的内容进行保存.(这些是主要参数,以后需要自定义其他参数再做调整)

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

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