Kafka的安装和使用

service iptables stop 关闭防火墙
service iptables start 启动防火墙
service iptables status 查看防火墙状态

kafka 是和zookeeper 共用的安装kafka前需安装zookeeper
zookeeper
1. 启动ZK服务: sh bin/zkServer.sh start
2. 查看ZK服务状态: sh bin/zkServer.sh status
3. 停止ZK服务: sh bin/zkServer.sh stop
4. 重启ZK服务: sh bin/zkServer.sh restart

你可以登录Apache kafka 官方下载。
http://kafka.apache.org/downloads.html

kafka
安装kafka完成后需要修改 /config/server.properties

listeners=PLAINTEXT://192.168.170.245:9092
zookeeper.connect=192.168.170.245:2181

bin/kafka-server-start.sh config/server.properties & 启动kafka
bin/kafka-topics.sh --zookeeper localhost:2181 --list 查看topic
jps 查看kafka的进程
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 消费者产生消息
netstat -tunlp|egrep “(2181|9092)” 查看端口

bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --topic testTwo --describe topic详细描述

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test创建消费者
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning 创建生产者