Current stateAdopted (2.1.0)

Discussion thread: TBD

JIRA: KAFKA-6998 - Getting issue details... STATUS

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).


StoreBuilder initializes itself as caching disabled, and only expose a withCachingEnabled() to flip this config via code. However, it does not provide a withCachingDisabled() function to allow users to flip it back, and hence restricting certain optimization opportunities (see KAFKA-6998 for details).

Public Interfaces

public interface StoreBuilder<T extends StateStore> {

     * Disable caching on the store.
     * @return  this
    StoreBuilder<T> withCachingDisabled();

Proposed Changes

As above.

Compatibility, Deprecation, and Migration Plan

  • There should be very minor compatibility issues since very rarely a user would extend the StoreBuilder interface themselves.

Rejected Alternatives


  • No labels