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

Reply via email to