前言：
如今兄弟们对“apachekafka安装配置”大概比较注意，咱们都需要剖析一些“apachekafka安装配置”的相关资讯。那么小编也在网摘上汇集了一些有关“apachekafka安装配置””的相关内容，希望朋友们能喜欢，我们一起来了解一下吧！1.java环境安装
sudo yum install java-11-openjdk.x86_64 -y
java -version
java有多个环境执行命令选择不同Java版本
sudo update-alternatives --config java
创建kafka用户
sudo useradd -r -s /bin/false kafka
下载解压 kafka
cd /opt/mkdir kafka
wget
创建设置 kafka目录
mkdir /var/lib/kafka
mkdir /var/lib/kafka/data
设置 kafka配置文件
vi /opt/kafka/config/server.properties
delete.topic.enable = true
log.dirs=/var/lib/kafka/data
更改目录用户权限:
chown -R kafka: /var/lib/kafka
chown -R kafka: /opt/kafka
2.安装zookeeper
下载文件：
wget
解压
tar -xvzf apache-zookeeper-3.6.1-bin.tar.gz
建目录配置
cd apache-zookeeper-3.6.1-bin
mkdir data
cp conf/zoo_sample.cfg conf/zoo.cfg
启动命令:
bin/zkServer.sh start
增加用户权限：
sudo useradd -r -s /bin/false zookeeper
chown zookeeper: -R apache-zookeeper-3.6.1-bin
配置 kafka,zookeeper 成服务
vi /usr/lib/systemd/system/zookeeper.service
[Unit]Description=Zookeeper Service[Service]Type=simpleWorkingDirectory=/opt/apache-zookeeper-3.6.1-bin/PIDFile=/opt/apache-zookeeper-3.6.1-bin/data/zookeeper_server.pidSyslogIdentifier=zookeeperUser=zookeeperGroup=zookeeperExecStart=/opt/apache-zookeeper-3.6.1-bin/bin/zkServer.sh startExecStop=/opt/apache-zookeeper-3.6.1-bin/bin/zkServer.sh stopRestart=alwaysTimeoutSec=20SuccessExitStatus=130 143Restart=on-failure[Install]WantedBy=multi-user.target
服务生效命令：
systemctl daemon-reload
systemctl start zookeeper
检查服务状态：
systemctl status zookeeper
开机自动启动
systemctl enable zookeeper
配置 kafka服务：
vi /usr/lib/systemd/system/kafka.service
[Unit]Requires=kafka.serviceAfter=kafka.serviceDescription=High-available, distributed message brokerAfter=network.target[Service]Type=simpleUser=kafkaExecStart=/bin/sh -c '/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties'ExecStop=/opt/kafka/bin/kafka-server-stop.shRestart=on-abnormal[Install]WantedBy=multi-user.target
systemctl daemon-reload
systemctl start kafka
systemctl status kafka
systemctl enable kafka
测试 kafka:
执行测试命令
1.创建topic
/opt/kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic Test
2.生产者命令
echo "Testing Kafka" | /opt/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic Test > /dev/null
2.消费者命令
/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic Test --from-beginning
成功安装kafka,zookeeper
版权声明：
本站文章均来自互联网搜集，如有侵犯您的权益，请联系我们删除，谢谢。
标签： #apachekafka安装配置 #centoskafka安装
