linux安装kafka

Apache官网 http://kafka.apache.org/downloads.html

tar -xzf kafka_2.10-0.8.2.2.tgz

cd kafka_2.10-0.8.2.2

KAFKA需要启动两个服务：

1，启动zookeeper： bin/zookeeper-server-start.sh config/zookeeper.properties &(&能在执行指令时退出 *** 作)

2，启动kafka： bin/kafka-server-start.sh config/server.properties &

1，创建topic

bin/kafka-topics.sh --create --zookeeper 10.202.4.179:2181 --replication-factor 1 --partitions 1 --topic test

创建一个名为test的topic，只有一个副本，一个分区。

2，创建生产者，启动producer

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

topic要对应之前创建的topic

之后便可以发送消息

3，创建消费者，启动consumer

bin/kafka-console-consumer.sh --zookeeper 10.202.4.179:2181 --topic test --from-beginning

topic要对应之前创建的topic

在生产者发送消息后，消费者便可以收到对应的消息了

http://blog.csdn.net/suifeng3051/article/details/48053965

Linux版kafka启动方式

方法一：

在bin的上一级目录执行命令：

加守护进程启动

方法二：

在bin的上一级目录执行命令：

通过后台来启动

ZooKeeper服务命令:

在准备好相应的配置之后，可以直接通过zkServer.sh 这个脚本进行服务的相关 *** 作

---