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
