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
