编程环境参见前面的 storm 的开发，还是使用 maven 项目。
由于使用的是 kafka 0.11.0.0版本，所以，必须在 pom.xml中加入下面一行代码：
阅读背景：
大数据生态系统基础：Apache Kafka基础（二）：最新kafka编程入门:Producer API
来源：互联网
分享到：
