windows kafka

下载kafka二进制包kafka_2.11-0.8.2.2.tgz，解压 

1.拷贝conf/server.properties为 
第一个节点server.properties，修改如下内容： 
broker.id=9093 
port=9093 
host.name=127.0.0.1
log.dirs=/tmp/kafka-logs-9093 
zookeeper.connect=localhost:2181 

第二个节点server.properties，修改如下内容： 
broker.id=9094 
port=9094 
host.name=127.0.0.1 
log.dirs=/tmp/kafka-logs-9094 
zookeeper.connect=localhost:2181

 

2.启动脚本 
第一个节点： 
cd kafka_2.10-0.8.1.1\bin\windows
kafka-server-start.bat  ..\..\config\server.properties

第二个节点： 
cd kafka_2.10-0.8.1.1_2\bin\windows
kafka-server-start.bat  ..\..\config\server.properties 


3.创建topic 
cd kafka_2.10-0.8.1.1\bin\windows 

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 2 --partitions 3 --topic my-replicated-topic 

4.查看topic描述信息 
cd kafka_2.10-0.8.1.1\bin\windows 

kafka-topics.bat --describe --zookeeper localhost:2181 --topic my-replicated-topic 

5.生产topic消息 
cd kafka_2.10-0.8.1.1\bin\windows 

kafka-console-producer.bat --broker-list localhost:9093 --topic my-replicated-topic 

6.消费topic消息 
cd kafka_2.10-0.8.1.1\bin\windows 

kafka-console-consumer.bat --zookeeper localhost:2181 --from-beginning --topic my-replicated-topic