Zookeeper是安装Kafka集群的必要组件,Kafka通过Zookeeper来实施对元数据信息的管理,包括集群、broker、主题、分区等内容。
Zookeeper是一个开源的分布式协调服务。三个角色:leader、follower、observer,同一时刻Zookeeper集群中只有一个leader,其他的都是follower和observer,observer不参与投票,默认情况下只有leader和follower两个角色。
注意停掉防火墙:
[root@localhost etc]# cat redhat-release
CentOS Linux release 7.9.2009 (Core)
[root@localhost zk-3.6.3]# service firewalld.service stop
Redirecting to /bin/systemctl stop firewalld.service
关键配置:
dataDir=/opt/soft/zookeeper/data server.1=192.168.10.100:2888:3888 server.2=192.168.10.101:2888:3888 server.3=192.168.10.102:2888:3888
在dataDir目录下编辑myid文件,填写相应的id
3. 安装Kafka下载后,修改config/server.properties,关键配置:
# The id of the broker. This must be set to a unique integer for each broker. broker.id=0 # The address the socket server listens on. It will get the value returned from # java.net.InetAddress.getCanonicalHostName() if not configured. # FORMAT: # listeners = listener_name://host_name:port # EXAMPLE: # listeners = PLAINTEXT://your.host.name:9092 listeners=PLAINTEXT://192.168.10.101:9092 # A comma separated list of directories under which to store log files log.dirs=/opt/soft/kafka/logs # Zookeeper connection string (see zookeeper docs for details). # This is a comma separated host:port pairs, each corresponding to a zk # server. e.g. "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002". # You can also append an optional chroot string to the urls to specify the # root directory for all kafka znodes. zookeeper.connect=192.168.10.100:2181/kafka,192.168.10.101:2181/kafka,192.168.10.102:2181/kafka
启动Kafka(前台方式),加入-daemon参数或者&后台运行
bin/kafka-server-start.sh config/server.properties



