由于公司需要使用kafka作为项目的一个消息中间件，所以不得不先提前了解下，下面都是我个人的踩的一些小坑，主要是设计到与java整合的地方。
下载地址 https://archive.apache.org/dist/kafka/
事先准备 由于消息都是保存到zk中的，所有我们的服务器中需要启动zookeeper。
kafka的启动 ./kafka‐server‐start.sh ‐daemon config/server.properties
创建主题 ./kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic luoli
启动producer ./kafka-console-producer.sh --broker-list 120.24.172.236:992 --topic luoli
启动consumer ./kafka-console-consumer.sh --bootstrap-server 120.24.172.236:9092 --consumer-property group.id=testGroup --topic luoli
但是在项目中向kafka发送消息还需要修改配置信息server.properties listeners=PLAINTEXT://:9092 advertised.host.name = 服务器的ip host.name = localhost
配置完成后就能实现发布和订阅了。 以上只是个人的简单实现，还有关于kafka底层原理及集群的实现等自己了解后再跟新上来。
