天天看點

zookeepr+kafka叢集--代碼實作(三)

項目基于maven建構,不得不說kafka java用戶端實在是太糟糕了;建構環境會遇到很多麻煩。建議參參考如下pom.xml;其中各個依賴包必須版本協調一緻。

四.Producer端代碼

1) producer.properties檔案:此檔案放在/resources目錄下

2) LogProducer.java代碼樣例

五.Consumer端

1) consumer.properties:檔案位于/resources目錄下

2) LogConsumer.java代碼樣例

在測試時,建議優先啟動consumer,然後再啟動producer,這樣可以實時的觀測到最新的消息。