Kafka入门+常用命令

bin/zookeeper-server-start.sh config/zookeeper.properties
1. 下载Kafka

http://archive.apache.org/dist/kafka/

2. 安装

Kafka是使用scala编写的运行与jvm虚拟机上的程序，虽然也可以在windows上使用，但是kafka基本上是运行在linux服务器上，（也可以运行在windows上）因此我们这里也使用linux来开始今天的实战。首先确保你的机器上安装了jdk，kafka需要java运行环境，以前的kafka还需要zookeeper，新版的kafka已经内置了一个zookeeper环境，所以我们可以直接使用。说是安装，如果只需要进行最简单的尝试的话我们只需要解压到任意目录即可

启动命令：

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

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

创建topic (例如创建topic名称为test的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

创建消费者（例如创建为test的消费者）

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

创建生产者（例如test）

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