You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Artur Mrozowski <ar...@gmail.com> on 2017/11/23 11:19:26 UTC
auto.offset.reset in 0.11.0.2 Kafka Streams does not take effect.
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
Re: auto.offset.reset in 0.11.0.2 Kafka Streams does not take effect.
Posted by Artur Mrozowski <ar...@gmail.com>.
Thank you Matthias!
On Thu, Nov 23, 2017 at 10:34 PM, Matthias J. Sax <ma...@confluent.io>
wrote:
> 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 <ar...@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
> >>
> >
>
>
Re: auto.offset.reset in 0.11.0.2 Kafka Streams does not take effect.
Posted by "Matthias J. Sax" <ma...@confluent.io>.
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 <ar...@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
>>
>
Re: auto.offset.reset in 0.11.0.2 Kafka Streams does not take effect.
Posted by Artur Mrozowski <ar...@gmail.com>.
Oh, I've got it. Need to reset the application id.
On Thu, Nov 23, 2017 at 12:19 PM, Artur Mrozowski <ar...@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
>