kafka java示例

我使用的kafka版本是：0.7.2 jdk版本是：1.6.0_20html http://kafka.apache.org/07/quickstart.html官方給的示例並非很完整，如下代碼是通過我補充的而且編譯後能運行的。java Producer Codeapache [java]  view plain copy import java.util.*;   import kafka.me

>>阅读原文<<