一、CentOS 7.9 安装 kafka_2.13地址
- https://kafka.apache.org/downloads.html
文章插图
二、安装准备1 安装JDK
在安装kafka之前必须先安装JDK和zookeeper,如何安装JDK,可以查看:CentOS 7.9 安装 jdk-8u333
2 下载安装zookeeper
如何在CentOS 7 下安装zookeeper,可以查看:CentOS 7.9 安装 zookeeper-3.6.3
二、kafka1 进入Apache官网
http://kafka.apache.org/downloads.html
选择Binary downloads,选择版本进行下载 。2 wget下载
wget https://archive.apache.org/dist/kafka/3.0.1/kafka_2.13-3.0.1.tgz
3 解压tar -zxvf /opt/software/kafka_2.13-3.0.1.tgz -C /opt/ll /opt/kafka_2.13-3.0.1/
4 进入kafka目录文章插图
5 启动kafka之前要确保zookeeper已经启动,如果没有启动,执行以下命令
zkServer.sh start
6 修改kafka配置文件中的zookeeper地址,打开配置文件vim /opt/kafka_2.13-3.0.1/config/server.properties# The id of the broker. This must be set to a unique integer for each broker.broker.id=0############################# Socket Server Settings ############################## 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:9092listeners=PLAINTEXT://192.168.0...:8091# Hostname and port the broker will advertise to producers and consumers. If not set,# it uses the value for "listeners" if configured.Otherwise, it will use the value# returned from java.net.InetAddress.getCanonicalHostName().#advertised.listeners=PLAINTEXT://your.host.name:9092# A comma separated list of directories under which to store log fileslog.dirs=/opt/kafka_2.13-3.0.1/logs############################# Zookeeper ############################## 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.0.98:2181# Timeout in ms for connecting to zookeeperzookeeper.connection.timeout.ms=18000
7 新建日志储存路径mkdir /opt/kafka_2.13-3.0.1/logs
8 启动kafka./bin/kafka-server-start.sh config/server.properties# 后台启动./bin/kafka-server-start.sh -daemon config/server.properties
四、设置开机自动启动1 切换到/lib/systemd/system/目录,创建自启动文件vim /lib/systemd/system/kafka.service[Unit]Description=kafkaserviceAfter=network.target[Service]WorkingDirectory=/opt/kafka_2.13-3.0.1ExecStart=/opt/kafka_2.13-3.0.1/bin/kafka-server-start.sh /opt/kafka_2.13-3.0.1/config/server.propertiesExecStop=/opt/kafka_2.13-3.0.1/bin/kafka-server-stop.shUser=rootGroup=rootRestart=alwaysRestartSec=10[Install]WantedBy=multi-user.target
2 设置自启动systemctl enable kafka.service
3 立即启动服务systemctl start kafka.service
4 查看启动状态systemctl status kafka.service
五、Kafka命令测试1 创建topic
./bin/kafka-topics.sh --bootstrap-server 192.168.0.98:8091 --create --topic iyuyixyz --partitions 2 --replication-factor 1
2 列出所有topic./bin/kafka-topics.sh --bootstrap-server 192.168.0.98:8091 --list
3 列出所有topic的信息./bin/kafka-topics.sh --bootstrap-server 192.168.0.98:8091 --describe
4 列出指定topic的信息./bin/kafka-topics.sh --bootstrap-server 192.168.0.98:8091 --describe --topic iyuyixyz
经验总结扩展阅读
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- 2023年2月安装机器黄道吉日 2023年2月哪天适合安装机器
- 2023年2月13日安装房门好不好 2023年2月13日安装房门行吗
- 2023年2月13日安装柱子好吗 2023年2月13日是安装柱子的黄道吉日吗
- 2023年农历九月初一安装房门吉日 2023年农历九月初一宜安装房门吗
- 2023年10月15日适合安装柱子吗 2023年10月15日安装柱子吉日一览表
- 2023年10月15日适合安装门户吗 2023年10月15日是安装门户吉日吗
- 2023年10月15日安装门框行吗 2023年10月15日是安装门框的黄道吉日吗
- 2023年2月13日是安装门框的黄道吉日吗 2023年农历正月廿三宜安装门框吗
- 2023年10月15日安装家电好吗 2023年农历九月初一宜安装家电吗
- 2023年2月13日安装门户吉日一览表 2023年2月13日安装门户行吗