THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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 "putAll" functionality allowing for bulk writes by the underlying state store implementation.
Public Interfaces
This KIP will add a method the to StateRestroreCallback
interface:
Code Block | ||
---|---|---|
| ||
void restoreAll(List<KeyValue<byte[], byte[]>>) |
Compatibility, Deprecation, and Migration Plan
- This is purely an addition of a new method. It will not cause any compatibility issues.
- This is purely an addition of a new method. It will not cause any compatibility issues.
Rejected Alternatives
N/A