kafka

一 . kafka 快速安装使用

1.1 下载kafka

地址

tar -xzf kafka_2.11-0.10.2.0.tgz
cd kafka_2.11-0.10.2.0

1.2 开启服务 启动ZooKeeper（如果没有可以启用默认的） 和Kafka

注意：下面启动是非后台启动，如果已启动ZooKeeper不需要第一步

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

后台启动

nohup bin/kafka-server-start.sh config/server.properties &
或者
bin/kafka-server-start.sh -daemon config/server.properties 

1.3 创建一个topic

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

查看topic

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

1.4 创建发送信息控制台(生产者)，发送信息(producer)

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

可以在控制台来发送信息

1.5 开启一个消费者(consumer)

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

资源：

http://kafka.apache.org/quickstart