Current state: Under Discussion

Discussion thread: here

JIRA: KAFKA-5363 - Getting 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.
    
    

Rejected Alternatives

N/A