Kafka的Producer和Consumer的示例(使用Java语言)
我使用的kafka版本是:0.7.2jdk版本是:1.6.0_20http://kafka.apache.org/07/quickstart.html官方给的示例并不是很完整,以下代码是经过我补充的并且编译后能运行的。分布式发布订阅消息系统 Kafka 架构设计 http://www.linuxidc.com/Linux/2013-11/92751.htmApache Kafka 代码实例 http://www.linuxidc.com/Linux/201...