Hello, I'm trying to read message from kafka which were not processed when topology was offline and restarted after a while.
I tried following config SpoutConfig spoutConfig = new SpoutConfig(hosts, PropertyManager.getProperty("kafka.spout.topic").toString(), "/" + PropertyManager.getProperty("kafka.spout.topic").toString(), UUID.randomUUID().toString()); spoutConfig.scheme = new SchemeAsMultiScheme(new StringScheme()); *spoutConfig.forceFromStart = true; * *spoutConfig.startOffsetTime = kafka.api.OffsetRequest.LatestTime();* and *spoutConfig.forceFromStart = false; * *spoutConfig.startOffsetTime = kafka.api.OffsetRequest.LatestTime();* None of them give me messages which were not read while topology was offline. Any help? -- Regards khazi