标签：关闭 permanent 官网 rom 日志 man replicat org available
最近公司项目需要用到kafka消息队列，所以特地花了一个周末的时间对kafka的搭建以及使用做了一个了解，特地记录一下。
kafka搭建需要依赖于zookeeper作为注册中心，前面两篇文已经介绍了zookeeper的环境搭建，现在将记录一下kafka的搭建，同样也是选取三个节点
如下：
Node1:192.168.153.133
Node2:192.168.153.137
Node3:192.168.153.138
/#进入下载目录 cd /usr/opt/ #下载kafka wget http://archive.apache.org/dist/kafka/1.0.0/kafka_2.11-1.0.0.tgz #解压文件并且重命名 tar -zxvf kafka_2.11-1.0.0.tgz && mv kafka_2.11-1.0.0 kafka
#修改日志存储地址 log.dirs=/usr/opt/kafka/data #节点id，用于区分子节点，就算是节点ip改变了，也能找到此节点 broker.id=1 #将使用外部的zookeeper配置 zookeeper.connect=192.168.153.133:2008,192.168.153.137:2008,192.168.153.138:2008 #指定主机地址，区分localhost，避免出错 host.name=192.168.153.137 #监听地址 listeners = PLAINTEXT://192.168.153.137:9092 #添加此项是为了api能够监听到此服务 advertised.listeners = PLAINTEXT://192.168.153.137:9092
#编辑环境配置
vim /etc/profile
加入以下配置：
export PATH=$PATH:$ZOOKEEPER_HOME/bin
export KAFKA_HOME=/usr/opt/kafka
然后生效配置文件：
#环境配置文件生效
source /etc/profile
后台启动kafka
./bin/kafka-server-start.sh -daemon config/server.properties
jps
bin/kafka-topics.sh --create --zookeeper 192.168.153.137:2181 --replication-factor 3 --partitions 1 --topic my-replicated-topic
查看主题列表 > bin/kafka-topics.sh --list --bootstrap-server 192.168.153.137:9092 启动控制台消费者 > bin/kafka-console-consumer.sh --bootstrap-server 192.168.153.137:9092 --topic my-replicated-topic--from-beginning 启动控制台消费者 > bin/kafka-console-consumer.sh --bootstrap-server 192.168.153.138:9092 --topic my-replicated-topic--from-beginning
firewall-cmd --zone=public --add-port=9092/tcp --permanent service firewalld stop
然后重启kafka即可
标签：关闭 permanent 官网 rom 日志 man replicat org available
原文地址：https://www.cnblogs.com/advanceBlog/p/11877003.html
