1. 下载安装包
官网下载地址:http://kafka.apache.org/downloads
选择一个版本下载,然后解压安装包。
2. 基本使用
2.1 启动kafka
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
bin/kafka-server-start.sh -daemon config/server.properties
启动后查看进程状态:
QuorumPeerMain:表示zookeeper进程;
Kafka:表示kafka进程;
2.2 创建Topic
bin/kafka-topics.sh –zookeeper localhost:2181 –partitions 1 –replication-factor 1 –create –topic ${topicName}
2.3 查看topic列表
bin/kafka-topics.sh –zookeeper localhost:2181 –list
2.4 查看某个Topic信息
bin/kafka-topics.sh –zookeeper localhost:2181 –describe –topic ${topicName}
2.5 创建生产者
bin/kafka-console-producer.sh –broker-list localhost:9092 –topic ${topicName}
2.6 创建消费者
bin/kafka-console-consumer.sh –bootstrap-server localhost:9092 –topic ${tpoicName} –from-beginning
2.7 停止kafka
bin/kafka-server-stop.sh
bin/zookeeper-server-stop.sh