1、解壓到目錄
tar -zxvf kafka_2.13-2.8.2.tgz -C /usr/local/kafka
2.進入目錄
cd /usr/local/kafka/kafka_2.13-2.8.2
3.查看版本(驗證是否已解壓)
bin/kafka-topics.sh --version
4.修改配置,注意:此配置中有一個默認的zookeeper的配置
vim config/server.properties
5.有三個配置要調整
#server.propertieslisteners=PLAINTEXT://:9092advertised.listeners=PLAINTEXT://<外網ip>:9092advertised.host.name=<內網ip>
6.示例配置
listeners=PLAINTEXT://:9092advertised.listeners=PLAINTEXT://8.219.68.237:9092advertised.host.name=127.0.0.1
7.啟動zk
sh -x bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
8、啟動kafka
#nohup /usr/local/kafka/kafka_2.13-2.8.2/bin/kafka-server-start.sh /usr/local/kafka/kafka_2.13-2.8.2/config/server.propertiesbin/kafka-server-start.sh config/server.properties &sh -x bin/kafka-server-start.sh -daemon config/server.properties
9、停止kafka
#關閉kafka#/usr/local/kafka/kafka_2.13-2.8.2/bin/kafka-server-stop.sh /usr/local/kafka/kafka_2.13-2.8.2/config/server.propertiesbin/kafka-server-stop.sh config/server.properties
設置開機自動服務
vi /lib/systemd/system/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:/usr/local/jdk/1.8.0_391/bin"
User=root
Group=root
ExecStart=/usr/local/kafka2.12/bin/kafka-server-start.sh /usr/local/kafka2.12/config/server.properties
ExecStop=/usr/local/kafka2.12/bin/kafka-server-stop.sh
Restart=on-failure
[Install]
WantedBy=multi-user.target
systemctl enable kafka.service #加入開機啟動
systemctl start kafka.service #啟動
systemctl stop kafka.service #停止
systemctl status kafka.service #狀態
創建topic
bin/kafka-topics.sh --create --bootstrap-server 192.168.0.133:9092 --replication-factor 1 --partitions 1 --topic demo002