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
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
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
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
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