Hi We had been using kafka 0.8 with Storm. It was upgraded to kafka_2.11-0.10.0.1 and Storm 1.1.1 as of now. Though the libraries changed the code pretty much remained the same.
Now we are trying to upgrade to version 1.2.2 of Storm and also look into KafkaSpoutRetryService. This also leads to using new KafkaSpoutConfig. What I fail to understand is where do I set properties related to zookeeper such as zkRoot in this new config. I also did not find any way to set following properties public int fetchSizeBytes = 1024 * 1024;public int socketTimeoutMs = 10000;public int fetchMaxWait = 10000;public int bufferSizeBytes = 1024 * 1024;public MultiScheme scheme = new RawMultiScheme();public boolean ignoreZkOffsets = false;public long startOffsetTime = kafka.api.OffsetRequest.EarliestTime();public long maxOffsetBehind = Long.MAX_VALUE;public boolean useStartOffsetTimeIfOffsetOutOfRange = true;public int metricsTimeBucketSizeInSecs = 60;
