免费视频淫片aa毛片_日韩高清在线亚洲专区vr_日韩大片免费观看视频播放_亚洲欧美国产精品完整版

使用ZooKeeper kafka搭建高可用集群。1 前提準(zhǔn)備ZooKeeper安裝包：apache-zookeeper-3.6.1-bin.tar.gzkafka安裝包：kafka_2.13-2.6.0.tgzjdk1.8及以上(自行配置環(huán)境變量)假設(shè)為三臺(tái)服務(wù)器搭建kafka集群（192.168.12.86、192.168.12.87、192.168.12.88）2 集群架構(gòu)2.1 ZooKeeper集群方案主機(jī)IP消息端口通信端口節(jié)點(diǎn)目錄192.168.12.8621812888:3888/db/dev/env/zookeeper/zk1192.168.12.8721812888:3888/db/dev/env/zookeeper/zk2192.168.12.8821812888:3888/db/dev/env/zookeeper/zk32.2 kafka集群主機(jī)IP集群通信端口節(jié)點(diǎn)目錄192.168.12.869092/db/dev/env/kafka/kafkaServer/kafka192.168.12.879092/db/dev/env/kafka/kafkaServer/kafka192.168.12.889092/db/dev/env/kafka/kafkaServer/kafka3 ZooKeeper集群搭建3.1 解壓安裝包[dev@datanode6 zookeeper]$ tar -zxvf apache-zookeeper-3.6.1-bin.tar.gz -C zkServer/3.2 修改配置文件配置環(huán)境變量命令：vim /etc/profile添加后#zookeeperexport ZOOKEEPER_HOME=/db/dev/env/zookeeper/zkServer/apache-zookeeper-3.6.1-binexport PATH=$ZOOKEEPER_HOME/bin:$PATH#JDKexport JAVA_HOME=/db/java8export JRE_HOME=$JAVA_HOME/jreexport CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$JRE_HOME/libexport PATH=$JAVA_HOME/bin:$JRE_HOME/bin:$PATH使環(huán)境變量生效：source /etc/profile添加zoo.cfgcd /opt/zookeeper/zookeeper-3.4.13/conf復(fù)制一份zoo_sample.cfg改名為zoo.cfg并添加配置cp zoo_sample.cfg zoo.cfgvim zoo.cfg修改為：dataDir=/db/dev/env/zookeeper/zkServer/apache-zookeeper-3.6.1-bin添加：vim zoo.cfgdataDir=/db/dev/env/zookeeper/zkServer/zkinfo/data/data_1dataLogDir=/db/dev/env/zookeeper/zkServer/zkinfo/logs/logs_1server.0=192.168.12.86:2888:3888server.1=192.168.12.87:2888:3888server.2=192.168.12.88:2888:3888添加data文件夾：[root@hadoop2 zookeeper-3.4.13]# mkdir data創(chuàng)建myid根據(jù)serverip對(duì)應(yīng)填寫0 1 2[root@hadoop2 data]# vim myid3.3 修改防火墻打開對(duì)應(yīng)端口（以下命令為centos6 請(qǐng)自行為端口打開防火墻）vi /etc/sysconfig/iptables添加-A INPUT -p tcp -m state --state NEW -m tcp --dport 22 -j ACCEPT-A INPUT -p tcp -m state --state NEW -m tcp --dport 2181 -j ACCEPT-A INPUT -p tcp -m state --state NEW -m tcp --dport 2888 -j ACCEPT-A INPUT -p tcp -m state --state NEW -m tcp --dport 3888 -j ACCEPT備注：這里使用2181/2888/3888是Zookeeper需要用到的端口號(hào)，22端口是用來遠(yuǎn)程的端口，可以不用添加。一般將需要開放的端口號(hào)添加到“-A INPUT -p tcp -m state --state NEW -m tcp--dport 22 -j ACCEPT”行的上面或者下面，切記不要添加到最后一行，否則防火墻重啟后不生效重啟防火墻：service iptables restart 3.4 啟動(dòng) ZooKeeperzkServer.sh start查看狀態(tài)zkServer.sh status4 Kafka搭建集群4.1 請(qǐng)將程序包放到相應(yīng)的目錄下解壓操作cd /kafka/configvim server.properties//三個(gè)節(jié)點(diǎn)都要根據(jù)不同的ip 設(shè)置broker.id=0 1 2broker.id=0delete.topic.enable=truelisteners=PLAINTEXT://192.168.12.8*:9092log.dirs==/db/dev/env/kafka/kafkaServer/kafkainfo/kafka-logs1zookeeper.connect=192.168.12.86:2181,192.168.12.87:2181,192.168.12.88:2181cd bin./kafka-server-start.sh -daemon ../config/server.propertiesjps 后出現(xiàn)20613 QuorumPeerMain38582 Kafka來源：https://www.icode9.com/content-4-733101.html