Since local cluster has in process zoookeper so I tried it in a distributed
cluster. But was not able to get those messages
On Mon, Mar 9, 2015 at 3:27 PM, Tousif <tousif.pa...@gmail.com> wrote:
> 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
>
>
--
Regards
Tousif Khazi
