Current state: Under Discussion

Discussion thread: here

JIRA: Unable to render Jira issues macro, execution error.

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.
    
    

Rejected Alternatives

N/A