You might want to consider using the reset tool instead of just changing the application.id...
https://www.confluent.io/blog/data-reprocessing-with-kafka-streams-resetting-a-streams-application/ -Matthias On 11/23/17 3:34 AM, Artur Mrozowski wrote: > Oh, I've got it. Need to reset the application id. > > On Thu, Nov 23, 2017 at 12:19 PM, Artur Mrozowski <art...@gmail.com> wrote: > >> Hi, >> I am running a Kafka Streams application and want to read everything from >> the topic from the beginning. >> So I renamed all the stores and set (ConsumerConfig.AUTO_OFFSET_ >> RESET_CONFIG,"earliest") >> but it does not take effect. Nothing happens. >> >> As soon as I put new messages than the processing and output takes off for >> the latest messages but I'd like to consume everything there is on the >> topic. >> >> Not sure what I am missing here. >> >> /Artur >> >
signature.asc
Description: OpenPGP digital signature
