Perf tuning is always tricky... 350 rec/sec sounds pretty low though.
You would first need to figure out where the bottleneck is. Kafka
Streams exposes all kind of metrics:
https://kafka.apache.org/documentation/#kafka_streams_monitoring
Might be good to inspect them as a first step -- maybe
I was able to get my test to complete correctly setting the internal
setting and removing the calls to set the wall clock.
props.put(InternalConfig.EMIT_INTERVAL_MS_KSTREAMS_OUTER_JOIN_SPURIOUS_RESULTS_FIX,
0L);
Thanks Shashwat and Matthias for giving me two solutions.
On Thu, Apr 4, 2024 at
The Apache Kafka community is pleased to announce the release for
Apache Kafka 3.6.2
This is a bug fix release and it includes fixes and improvements from 28 JIRAs.
All of the changes in this release can be found in the release notes:
https://www.apache.org/dist/kafka/3.6.2/RELEASE_NOTES.html