org.apache.kafka.streams.kstream

Interface Suppressed.EagerBufferConfig

All Superinterfaces:

Suppressed.BufferConfig<Suppressed.EagerBufferConfig>

Enclosing interface:

Suppressed<K>

public static interface Suppressed.EagerBufferConfig
extends Suppressed.BufferConfig<Suppressed.EagerBufferConfig>

Marker interface for a buffer configuration that will strictly enforce size constraints (bytes and/or number of records) on the buffer, so it is suitable for reducing duplicate results downstream, but does not promise to eliminate them entirely.

Method Summary

Methods inherited from interface org.apache.kafka.streams.kstream.Suppressed.BufferConfig

emitEarlyWhenFull, maxBytes, maxRecords, shutDownWhenFull, unbounded, withMaxBytes, withMaxRecords, withNoBound