0
系統環境:卡夫卡壺嘴配置錯誤
風暴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 ..