这篇文章不是我写的,只是借用,以后肯定用的着
http://www.cnblogs.com/wangb0402/p/6187796.html

配置弄好后


cosumer的配置




KafkaConsumerServer.java //消费者监听

kafkaProducerListener.java //生产者监听-打印日志


KafkaProducerServer.java //生产者






具体项目代码
项目地址:https://git.oschina.net/wsmd/kafka-0.10-demo
网友评论