Kafka安装配置(kafka_2.9.2-0.8.1.1)

1.本次选用3台机器测试

10.58.22.219 fk01
10.58.22.221 S1PA124
10.58.22.220 S1PA123

2.安装好zookeeper-3.4.6

zookeeper安装也很简单，在此就省略了

3.安装kafka

安装文件准备

(1)下载kafka_2.9.2-0.8.1.1.tar.gz

(2)解压缩 tar -zxvf kafka_2.9.2-0.8.1.1.tar.gz

(3)复制到另外两台机器

scp -r kafka_2.10-0.8.1 root@fk01:/root/install/
scp -r kafka_2.10-0.8.1 root@S1PA123:/root/install/

环境配置


（1）修改server.properties

broker.id： 唯一标识(S1PA124=221,fk01=219,S1PA123=220)
host.name：为当前机器的IP地址或主机名
（2）配置zookeeper访问地址
zookeeper.connect=S1PA124:2181,S1PA123:2181,fk01:2181
（3）log.dirs=数据存放目录

4.启动服务
（1）在每台机器上先启动zookeeper服务
bin/zkServer.sh start

（2）接着在每台机器上启动kafka服务
bin/kafka-server-start.sh config/server.properties

5.简单的使用
（1）创建topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 1
--topic hello-kafka
（2）查看topic
bin/kafka-topics.sh --list --zookeeper localhost:2181

（3）查看详细的topic
  bin/kafka-topics.sh --describe --zookeeper 10.58.22.221:2181
（4）删除Topic
bin/kafka-run-class.sh kafka.admin.DeleteTopicCommand --topic hello-kafka --zookeeper fk01:2181,S1PA124:2181,S1PA124:2181