kafka安装及配置

1、安装及配置zookeeper

tar -xf zookeeper-3.3.6.tar.gz 

cd zookeeper/conf  

cp zoo_sample.cfg zoo.cfg

vim zoo.cfg  

#修改如下：

dataDir=/opt/data/zookeeper  

dataLogDir=/opt/data/zookeeper/log 

clientPort=2181 

#注意：如果出现拒绝连接，请检查防火墙是否关闭  systemctl stop firewalld

sh /usr/local/suninfo/tools/zookeeper/bin/zkServer.sh start

#########################################################################################################################################

2、安装及配置kafka

tar -xf kafka_2.12-1.0.0.tgz 

cd kafka_2.12/config

vim server.properties  

#修改如下：

advertised.listeners=PLAINTEXT://192.168.212.59:9092

log.dirs=/usr/local/suninfo/kafka_2.10-0.10.2.1/logs/kafka-logs

zookeeper.connect=192.168.212.59:2181

delete.topic.enable=true

auto.create.topics.enable=true

#启动kafka

sh /usr/local/suninfo/tools/kafka/bin/kafka-server-start.sh /usr/local/suninfo/tools/kafka/config/server.properties &

#查看topic

/usr/local/suninfo/tools/kafka/bin/kafka-topics.sh --zookeeper 192.168.211.68:2181 --list

#创建topic

sh /usr/local/suninfo/tools/kafka/bin/kafka-topics.sh --create --zookeeper 192.168.211.68:2181 --replication-factor 1 --partitions 3 --topic loginfoTopic

#查看kafka客户端

sh /usr/local/suninfo/tools/kafka/bin/kafka-console-consumer.sh --zookeeper 192.168.211.68:2181 --from-beginning --topic loginfoTopic

#删除topic

sh /usr/local/suninfo/tools/kafka/bin/kafka-topics.sh --zookeeper 192.168.211.68:2181 --delete --topic loginfoTopic

########################################################################################################################################

3、安装及配置kafka-manager

vim /usr/local/suninfo/tools/kafka/bin/kafka-server-start.sh  
在这个sh文件下加上：

export JMX_PORT="9999"

sh /usr/local/suninfo/tools/kafka-manager/bin/kafka-manager -Dconfig.file=conf/application.conf &