項目基于maven建構,不得不說kafka java用戶端實在是太糟糕了;建構環境會遇到很多麻煩。建議參參考如下pom.xml;其中各個依賴包必須版本協調一緻。
四.Producer端代碼
1) producer.properties檔案:此檔案放在/resources目錄下
2) LogProducer.java代碼樣例
五.Consumer端
1) consumer.properties:檔案位于/resources目錄下
2) LogConsumer.java代碼樣例
在測試時,建議優先啟動consumer,然後再啟動producer,這樣可以實時的觀測到最新的消息。