Please check your retention policy.
I think you are expecting data beyond your retention period.
Regards,
Ashiq
> On 25-Apr-2016, at 9:26 PM, Ole Kozaczenko <okozacze...@goodgamestudios.com>
> wrote:
>
> Hey guys,
>
> I have the following system: Kafka (0.8.2.1) ist getting messages per HTTP
> and a Spark parser is consuming them. Now on the weekend the parser broke,
> and some events were not processed. How do I reprocess them?
> I already tried spawning a 2nd parser, with auto-offset "smallest" and
> another groupID:
>
> val kafkaParams = Map[String, String]("metadata.broker.list" ->
> brokers,"group.id" -> "reprocessing2", "auto.offset.reset" -> "smallest")
>
> But that doesn't work, it's not starting from the 1st message in the topic.
>
> Any ideas?
>
> Thanks!
>
> --
>
> *Ole Kozaczenko*
> Junior Java Enterprise Developer
> *okozacze...@goodgamestudios.de <okozacze...@goodgamestudios.de>*
>
> Goodgame Studios
> Theodorstr. 42-90, House 11
> 22761 Hamburg, Germany
> Phone: +49 (0)40 219 880 -0
> *www.goodgamestudios.com <http://www.goodgamestudios.com>*
>
> Goodgame Studios is a brand of Altigi GmbH
> Altigi GmbH, District court Hamburg, HRB 99869
> Board of directors: Dr. Kai Wawrzinek, Dr. Christian Wawrzinek, Fabian
> Ritter
