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