c 网站开发用的人多吗,百度seo关键词外包,泊头 网站优化,666建筑人才网文章目录一、基础软件下载1. JDK2. KAFKA3. ZOOKEEPER二、zookeeper配置启动2.1. 解压2.2. 配置环境变量2.3. 刷新环境变量2.4. 配置文件调整2.4. 启动zookeeper2.5. 监控zk启动状态2.6. 查看日志三、kafka配置启动3.1. 解压3.2. 配置环境变量3.3. 刷新环境变量3.4. 验证是否生… 文章目录一、基础软件下载1. JDK2. KAFKA3. ZOOKEEPER二、zookeeper配置启动2.1. 解压2.2. 配置环境变量2.3. 刷新环境变量2.4. 配置文件调整2.4. 启动zookeeper2.5. 监控zk启动状态2.6. 查看日志三、kafka配置启动3.1. 解压3.2. 配置环境变量3.3. 刷新环境变量3.4. 验证是否生效3.5. 配置文件3.6. 数据目录配置3.7. 创建数据目录3.8. 启动kafka3.9. 登录zk验证节点3.10. kafka服务停止3.11. 环境变量一、基础软件下载 1. JDK Linux 安装、卸载JDK 2. KAFKA http://kafka.apache.org/downloads wget https://dlcdn.apache.org/kafka/2.8.0/kafka_2.12-2.8.0.tgz3. ZOOKEEPER https://archive.apache.org/dist/zookeeper/ wget https://archive.apache.org/dist/zookeeper/zookeeper-3.7.0/apache-zookeeper-3.7.0-bin.tar.gz二、zookeeper配置启动 2.1. 解压 cd /app tar -zxvf apache-zookeeper-3.7.0-bin.tar.gz mv apache-zookeeper-3.7.0-bin zookeeper-3.7.02.2. 配置环境变量 vim /etc/profile# ZK export ZOOKEEPER_HOME/app/zookeeper-3.7.0 export PATH$PATH:${ZOOKEEPER_HOME}/bin # 修改zk保存数据文件的目录 export ZK_LOG_DIR/var/gblfy/zookeeper/log2.3. 刷新环境变量 source /etc/profile2.4. 配置文件调整 cd zookeeper-3.7.0/conf/ cp zoo_sample.cfg zoo.cfg vim zoo.cfg将dataDir/tmp/zookeeper调整为 dataDir/var/gblfy/zookeeper/data2.4. 启动zookeeper cd /app/zookeeper-3.7.0/bin ./zkServer.sh start2.5. 监控zk启动状态 ./zkServer.sh status2.6. 查看日志 cd /var/gblfy/zookeeper三、kafka配置启动 3.1. 解压 tar -zxvf kafka_2.12-2.8.0.tgz3.2. 配置环境变量 vim /etc/profile#kafaka export KAFKA_HOME/app/kafka_2.12-2.8.0 export PATH$PATH:${KAFKA_HOME}/bin3.3. 刷新环境变量 source /etc/profile3.4. 验证是否生效 输入kafka-按Tab键命令补全如果自动显示下面这些脚本说明配置环境变量生效3.5. 配置文件 1.指定 kafka在哪存储消息持久化的数据目录 2.kafka连接zookeeper的地址以及kafka的节点 cd /app/kafka_2.12-2.8.0/config/ vim server.properties将#zookeeper.connectlocalhost:2181 修改为 zookeeper.connectlocalhost:2181/mykafka # 在zk根目录下会创建一个mykafka节点这个节点的子节点存放的是kafka的元数据3.6. 数据目录配置 将 #log.dirs/tmp/kafka-logs 修改为 log.dir/var/gblfy/kafka/kafka-logs #指定 kafka在哪存储消息持久化的数据的目录3.7. 创建数据目录 mkdir /var/gblfy/kafka/kafka-logs -p3.8. 启动kafka # 独占前台模式启动kafka kafka-server-start.sh ../config/server.properties # 后台启动kafka kafka-server-start.sh -daemon /app/kafka_2.12-2.8.0/config/server.properties 3.9. 登录zk验证节点 登录zk在根目录下面是否是否创建mykafka节点 # 登录zk zkCli.sh # 查看zk根节点 ls /# 查看mykafka里面的子节点 ls /mykafka[zk: localhost:2181(CONNECTED) 0] ls / [mykafka, zookeeper] [zk: localhost:2181(CONNECTED) 1] ls /mykafka [cluster,集群controller, 控制器controller_epoch,控制器的纪元brokers,kafka实例有哪些admin, 管理者isr_change_notification, 同步的副本consumers, 消费者log_dir_event_notification, log_dir的一个事件通知latest_producer_id_block, 最后一个生产者config] [zk: localhost:2181(CONNECTED) 2] 到目前这一步节点创建成功了kafka启动也没问题 3.10. kafka服务停止 # 停止kafka服务 kafka-server-stop.sh3.11. 环境变量 export JAVA_HOME/data/soft/jdk1.8 export ZOOKEEPER_HOME/app/zookeeper-3.7.0 export KAFKA_HOME/app/kafka_2.12-2.8.0 export PATH.:$JAVA_HOME/bin:$KAFKA_HOME/bin:$ZOOKEEPER_HOME/bin:$PATH scl enable devtoolset-9 bash# 修改zk保存数据文件的目录 export ZK_LOG_DIR/var/gblfy/zookeeper/log