解压安装
tar -xzf kafka_2.13-2.8.0.tgz -C /opt cd /opt/ mv kafka_2.13-2.8.0 kafka cd kafka mkdir logs cd config vim server.properties添加相关参数
- broker.id 唯一id
- log.dirs 日志目录
- zookeeper.connect 使用外部zookeeper
#broker 的全局唯一编号，不能重复 broker.id=0 #删除 topic 功能使能 delete.topic.enable=true #kafka 运行日志存放的路径 log.dirs=/opt/module/kafka/logs #配置连接 Zookeeper 集群地址 zookeeper.connect=server1:2181,server2:2181,server3:2181分发 添加环境变量
sudo vi /etc/profile
#KAFKA_HOME export KAFKA_HOME=/opt/kafka export PATH=$PATH:$KAFKA_HOME/bin
source /etc/profile测试
各个节点启动
bin/kafka-server-start.sh config/server.properties &
停止服务
bin/kafka-server-stop.sh stop
相关命令：创建主题、描述主题、打开生产者、打开消费者
bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092 bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092 bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092 bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
