TOP

CentOS 7 安装配置 kafka,并配置开机自启(systemctl)
2019-04-27 14:30:31 】 浏览:941
Tags:CentOS 安装 配置 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

完工!!!


CentOS 7 安装配置 kafka,并配置开机自启(systemctl) https://www.cppentry.com/bencandy.php?fid=120&id=220725

】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇        .. 下一篇kafka->logstash->es