From dd55081192b6272277e2db15032977296b9d10ef Mon Sep 17 00:00:00 2001
From: vamossagar12 Streams API
into the constructor, it is no longer required to set mandatory configuration parameters
(cf. KIP-680).
+ We added the prefixScan()
method to interface ReadOnlyKeyValueStore
.
+ The new prefixScan()
allows fetching all values whose keys start with a given prefix.
+ See KIP-614 for more details.
+
Kafka Streams is now handling TimeoutException
thrown by the consumer, producer, and admin client.
If a timeout occurs on a task, Kafka Streams moves to the next task and retries to make progress on the failed