CentOS 7 安装配置 kafka,并配置开机自启(systemctl) |
您所在的位置:网站首页 › 配置systemctl服务启动 › CentOS 7 安装配置 kafka,并配置开机自启(systemctl) |
安装 kafka 需要先安装 jdk。
一、下载
官网:http://kafka.apache.org/downloads.html 二、安装安装参考:https://segmentfault.com/a/1190000012990954 1. 解压安装(我的安装目录/opt/kafka/) # tar -zvxf kafka_2.11-2.1.0.tgz 2. 修改配置 # vim /opt/kafka/kafka_2.11-2.1.0/config/server.properties 3. 修改其中 listeners=PLAINTEXT://ip:9092 注:ip指的是本机ip地址 三、验证1. 使用安装包中的脚本启动单节点Zookeeper实例: # cd /opt/kafka/kafka_2.11-2.1.0 # bin/zookeeper-server-start.sh -daemon config/zookeeper.properties 2. 使用kafka-server-start.sh启动kafka服务: # bin/kafka-server-start.sh config/server.properties 3. 使用kafka-topics.sh 创建但分区单副本的topic test # bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test 4. 使用kafka-console-producer.sh 发送消息 # bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 5. 使用kafka-console-consumer.sh 接收消息并在终端打印 # bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning 四、配置开机自启(systemctl)1. 在 /lib/systemd/system/ 目录下创建 zookeeper服务和kafka服务 的配置文件。 # vim zookeeper.service zookeeper.service 添加内容: [Unit] Description=Zookeeper service After=network.target [Service] Type=simple Environment="PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin:/opt/java/jdk-11.0.1/bin" User=root Group=root ExecStart=/opt/kafka/kafka_2.11-2.1.0/bin/zookeeper-server-start.sh /opt/kafka/kafka_2.11-2.1.0/config/zookeeper.properties ExecStop=/opt/kafka/kafka_2.11-2.1.0/bin/zookeeper-server-stop.sh Restart=on-failure [Install] WantedBy=multi-user.target # vim kafka.service kafka.service 添加内容: [Unit] Description=Apache Kafka server (broker) After=network.target zookeeper.service [Service] Type=simple Environment="PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin:/opt/java/jdk-11.0.1/bin" User=root Group=root ExecStart=/opt/kafka/kafka_2.11-2.1.0/bin/kafka-server-start.sh /opt/kafka/kafka_2.11-2.1.0/config/server.properties ExecStop=/opt/kafka/kafka_2.11-2.1.0/bin/kafka-server-stop.sh Restart=on-failure [Install] WantedBy=multi-user.target 注:以上两个文件 根据自己的 jdk 和 kafka 安装目录相应的修改。 2. 刷新配置。 # systemctl daemon-reload 3. zookeeper、kafka服务加入开机自启。 #systemctl enable zookeeper #systemctl enable kafka 4. 使用systemctl启动/关闭/重启 zookeeper、kafka服务systemctl start/stop/restart zookeeper/kafka。 注:启动kafka前必须先启动zookeeper 。 # systemctl start zookeeper # systemctl start kafka 5. 查看状态。 # systemctl status zookeeper # systemctl status kafka 完工!!! |
今日新闻 |
推荐新闻 |
CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3 |