カフカ注ぎ口の構成エラー

Question

システム環境：1.7.0_55、ベンダー：オラクル・コーポレーション

OS名

のApache Mavenの3.0.5

Javaのバージョンをインキュベート

嵐0.9.2： "linux"、バージョン： "3.13.0-24-ジェネリック"、アーチ： "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; 

私はstorm kafkaの統合に成功しましたが、私は飼い牛のオフセットを無視する必要があります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を使用する例を挙げてください。

Answer 1

SpoutConfigに間違ったパッケージをインポートしています。

（ストームコア Mavenの依存で入手可能）org.apache.storm.kafka.SpoutConfigを使用してみてください代わりに（ストームカフカ Mavenの依存で入手可能）storm.kafka.SpoutConfig。