Current state: Under Discussion
Discussion thread: here
JIRA:
-
KAFKA-5363Getting issue details...
STATUS
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
Motivation
Currently, when restoring a state store in a Kafka Streams application, we put one key-value at a time into the store. This proposal aims to make this recovery more efficient by allowing for a "restoreAll" functionality allowing for bulk writes by the underlying state store implementation.
Public Interfaces
This KIP will add a method the to StateRestroreCallback
interface:
void restoreAll(List<KeyValue<byte[], byte[]>>)
Compatibility, Deprecation, and Migration Plan
- This proposal adds a method to an existing interface. All classes using this interface will have to add an implementation for this method.
- This proposal adds a method to an existing interface. All classes using this interface will have to add an implementation for this method.
Rejected Alternatives
N/A