标签：
Kafka的介绍和入门请看这里kafka入门：简介、使用场景、设计原理、主要配置及集群搭建（转）
当前文章从实践的角度为大家规避window下使用的坑。
1.要求：
java 8
2.下载kafka【注意，只用下载kafka】
http://mirrors.cnnic.cn/apache/kafka/0.9.0.1/kafka_2.11-0.9.0.1.tgz
3.解压，通过cmd进入kafka_2.11-0.9.0.1\bin\windows目录
4.启动zk
zookeeper-server-start ..\..\config\zookeeper.properties
测试连接一下
zookeeper-shell.bat 0.0.0.0:2181
5.启动Kafka
kafka-server-start.bat ..\..\config\server.properties
6)创建topic
Created topic "mytopic".----------------------------------------------------------Topic:mytopic PartitionCount:3 ReplicationFactor:1 Configs: Topic: mytopic Partition: 0 Leader: 0 Replicas: 0 Isr: 0 Topic: mytopic Partition: 1 Leader: 0 Replicas: 0 Isr: 0 Topic: mytopic Partition: 2 Leader: 0 Replicas: 0 Isr: 0bin\windows>kafka-console-producer.bat --broker-list localhost:9092 --topic mytopic你真坚决
niaho
heelo
我是中文啊
bin\windows>kafka-console-consumer.bat --zookeeper localhost:2181 --from-beginning --topic mytopic--------------------------------------------------------------------
你真坚决
niaho
heelo
我是中文啊
--------------------------------------------------------------------
以上内容参考这里：http://kafka.apache.org/documentation.html#quickstart
ok,很完美.
出错问题：Unrecognized VM option UseG1GC 这些优化参数其实都是新版的，所以要么用jdk1.7+，要么去掉。
解决办法：打开conf\kafka-run-class.bat，找到102行，修改如下
IF ["%KAFKA_JVM_PERFORMANCE_OPTS%"] EQU [""] ( rem set KAFKA_JVM_PERFORMANCE_OPTS=-server -XX:+UseG1GC -XX:MaxGCPauseMillis=20 -XX:InitiatingHeapOccupancyPercent=35 -XX:+DisableExplicitGC -Djava.awt.headless=true set KAFKA_JVM_PERFORMANCE_OPTS=-server -XX:+DisableExplicitGC -Djava.awt.headless=true )
使用java调用kafka，参考http://blog.csdn.net/hxpjava1/article/details/19160665。
Kafka与spring集成，参考http://colobu.com/2014/11/19/kafka-spring-integration-in-practice/
标签：
原文地址：http://www.cnblogs.com/mignet/p/window_kafka.html
