卡夫卡壺嘴配置錯誤

風暴0.9.2培育

的Apache Maven的3.0.5

Java版本：1.7.0_55，供應商：Oracle公司

操作系統名稱：「linux」，版本：「3.13.0-24-generic」，arch：「i386」，系列：「unix」

這裏是我的代碼：

 Config conf = new Config(); 
     conf.setDebug(true); 



     String zkConnString = "localhost:2181"; 
     String topic = "tap"; 
     BrokerHosts hosts = new ZkHosts(zkConnString); 


     SpoutConfig kafkaSpoutConfig = new SpoutConfig (hosts, topic, "/" + topic, UUID.randomUUID().toString()); 
     kafkaSpoutConfig.bufferSizeBytes = 1024 * 1024 * 4; 
     kafkaSpoutConfig.fetchSizeBytes = 1024 * 1024 * 4; 

     kafkaSpoutConfig.ignoreZKOffsets = true;

我做了風暴kafka集成成功，但我需要忽略zookeeper偏移kafkaSpoutConfig.ignoreZKOffsets = true;但是當我試圖用maven構建時，我得到了一個錯誤。

cannot find symbol 
    symbol: variable ignoreZKOffsets 
    location: variable kafkaSpoutConfig of type storm.kafka.SpoutConfig 
[INFO] 1 error 
[INFO] ------------------------------------------------------------- 
[INFO] ------------------------------------------------------------------------ 
[INFO] BUILD FAILURE

如何忽略zkoffests？請舉一個例子來使用zkoffests ..

來源

2017-07-26 midhunxavier

您正在導入SpoutConfig的錯誤軟件包。

嘗試使用org.apache.storm.kafka.SpoutConfig（在風暴核行家依賴性可用）代替storm.kafka.SpoutConfig（在風暴卡夫卡行家依賴性可用）。

來源

2017-08-04 12:09:14

卡夫卡壺嘴配置錯誤

回答

相關問題