Class InMemoryTimeOrderedKeyValueBuffer.Builder<K,​V>

    • Constructor Detail

      • Builder

        public Builder​(java.lang.String storeName,
                       org.apache.kafka.common.serialization.Serde<K> keySerde,
                       org.apache.kafka.common.serialization.Serde<V> valSerde)
    • Method Detail

      • withCachingEnabled

        public StoreBuilder<InMemoryTimeOrderedKeyValueBuffer<K,​V>> withCachingEnabled()
        As of 2.1, there's no way for users to directly interact with the buffer, so this method is implemented solely to be called by Streams (which it will do based on the cache.max.bytes.buffering config.

        It's currently a no-op.

        Specified by:
        withCachingEnabled in interface StoreBuilder<K>
        Returns:
        this
      • withCachingDisabled

        public StoreBuilder<InMemoryTimeOrderedKeyValueBuffer<K,​V>> withCachingDisabled()
        As of 2.1, there's no way for users to directly interact with the buffer, so this method is implemented solely to be called by Streams (which it will do based on the cache.max.bytes.buffering config.

        It's currently a no-op.

        Specified by:
        withCachingDisabled in interface StoreBuilder<K>
        Returns:
        this
      • withLoggingEnabled

        public StoreBuilder<InMemoryTimeOrderedKeyValueBuffer<K,​V>> withLoggingEnabled​(java.util.Map<java.lang.String,​java.lang.String> config)
        Description copied from interface: StoreBuilder
        Maintain a changelog for any changes made to the store. Use the provided config to set the config of the changelog topic.
        Specified by:
        withLoggingEnabled in interface StoreBuilder<K>
        Parameters:
        config - config applied to the changelog topic
        Returns:
        this
      • logConfig

        public java.util.Map<java.lang.String,​java.lang.String> logConfig()
        Description copied from interface: StoreBuilder
        Returns a Map containing any log configs that will be used when creating the changelog for the StateStore.

        Note: any unrecognized configs will be ignored by the Kafka brokers.

        Specified by:
        logConfig in interface StoreBuilder<K>
        Returns:
        Map containing any log configs to be used when creating the changelog for the StateStore If loggingEnabled returns false, this function will always return an empty map
      • name

        public java.lang.String name()
        Description copied from interface: StoreBuilder
        Return the name of this state store builder. This must be a valid Kafka topic name; valid characters are ASCII alphanumerics, '.', '_' and '-'.
        Specified by:
        name in interface StoreBuilder<K>
        Returns:
        the name of this state store builder