Endless loop restoring changelog topic

2021-07-20 Thread Alessandro Tagliapietra
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

Issue with using open messaging

2021-07-20 Thread Rahul Pandey
Hi there, I'm trying to use open messaging to run some benchmarks for Kafka I've done the prerequisite setup for machines using terraform machine and ansible now while running the benchmark with sudo bin/benchmark --drivers driver-kafka/kafka.yaml workloads/1-topic-16-partitions-1kb.yaml , I'm

Re: Endless loop restoring changelog topic

2021-07-20 Thread Alessandro Tagliapietra
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

Re: Endless loop restoring changelog topic

2021-07-20 Thread Alessandro Tagliapietra
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. 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

Endless loop restoring changelog topic

2021-07-20 Thread Alessandro Tagliapietra
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