Linux安装kafka详解

kafka安装

1.下载kafka

Wget http://mirrors.cnnic.cn/apache/kafka/0.10.0.1/kafka_2.10-0.10.0.1.tgz

tar -zxvf kafka_2.10-0.10.0.1.tgz

mv kafka_2.10-0.10.0.1 /usr/local/kafka

2.配置kafka

cd /usr/local/kafka/config vim zookeeper.properties

#文件中dataDir=/tmp/zookeeper代表zookeeper数据存储路径，clientPort=1888代表zookeeper的端口号为：1888，消费者需要监听的端口（如果已经安装过zookeeper则不需要此步）

#修改kafka的server配置

vim server.properties

#把listeners行的注释去掉，这个表示kafka消息队列的监听端口，用于生产者监听使用

#把listeners修改为如下：

listeners=PLAINTEXT://你的ip地址:9092（kafka端口（自定义））

#倒数第三行 ‘zookeeper.connect=localhost:1888’（端口为你已经安装zookeeper的端口） 代表连接zookeeper

4.简单使用

kafka启动顺序：先启动zookeeper，再启动kafka server

cd /usr/local/kafka

#启动zookeeper（窗口1）

bin/zookeeper-server-start.sh config/zookeeper.properties

（如果已经安装过zookeeper则不需要此步）

#启动kafka（窗口2）

cd /usr/local/kafka

nohup bin/kafka-server-start.sh config/server.properties

#启动消费者（窗口3）

cd /usr/local/kafka

bin/kafka-console-consumer.sh --bootstrap-server 10.62.8.49:9092 --topic alarm_occur --from-beginning

#启动生产者（窗口4）

cd /usr/local/kafka

bin/kafka-console-producer.sh --broker-list 10.62.8.49:9092 --topic alarm_occur

#随便写入消息后回车，这时窗口3的消费者就会立即显示你写入的消息

列出所有Topic

bin/kafka-topics.sh --zookeeper localhost:1888 --list

删除指定的topic

bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic CreateAlarm