You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by "Matthias J. Sax" <mj...@apache.org> on 2021/11/16 18:13:02 UTC
Re: Endless loop restoring changelog topic
Not sure.
Can you enable DEBUG logging on
`org.apache.kafka.streams.processor.internals.StoreChangelogReader` to
see if restore does make any progress?
-Matthias
On 7/20/21 5:41 AM, Alessandro Tagliapietra wrote:
>> I've tried to restart the streams application using at_least_once
>> processing guarantee and it worked, restarted again in
>> exactly_once_beta and it worked too.
>>
> Spoke too soon, after a while in exactly_once_beta the "Restoration in
> progress for 1 partition" loop started again.
>
>
>> Is there any reason why?
>>
>> On 7/20/21 2:09 PM, Alessandro Tagliapietra wrote:
>>> Hello everyone,
>>>
>>> after upgrading to kafka streams 2.8 we have one streams app that's
>>> stuck trying to restore a store changelog topic, this is the debug
>>> log of the app:
>>>
>>> https://gist.github.com/alex88/f31593aaabbd282b21f89a0252a28745
>>>
>>> I would like to avoid having to delete and recreate the topic, what
>>> we should do?
>>>
>>> I've tried to switch back to exaclty_once (from exactly_once_beta)
>>> but nothing changed.
>>>
>>> Thank you in advance
>>>