Package org.apache.kafka.streams.kstream.internals.suppress

Class EagerBufferConfigImpl

java.lang.Object

org.apache.kafka.streams.kstream.internals.suppress.BufferConfigInternal<Suppressed.EagerBufferConfig>

org.apache.kafka.streams.kstream.internals.suppress.EagerBufferConfigImpl

All Implemented Interfaces:

Suppressed.BufferConfig<Suppressed.EagerBufferConfig>, Suppressed.EagerBufferConfig

public class EagerBufferConfigImpl
extends BufferConfigInternal<Suppressed.EagerBufferConfig>
implements Suppressed.EagerBufferConfig

Constructor Summary

Constructors

Constructor	Description
EagerBufferConfigImpl(long maxRecords, long maxBytes)

Method Summary

Modifier and Type	Method	Description
BufferFullStrategy	bufferFullStrategy()
boolean	equals(Object o)
Map<String,String>	getLogConfig()
int	hashCode()
boolean	isLoggingEnabled()
long	maxBytes()
long	maxRecords()
String	toString()
Suppressed.EagerBufferConfig	withLoggingDisabled()	Disable the changelog for this suppression's internal buffer.
Suppressed.EagerBufferConfig	withLoggingEnabled(Map<String,String> config)	Indicates that a changelog topic should be created containing the currently suppressed records.
Suppressed.EagerBufferConfig	withMaxBytes(long byteLimit)	Set a size constraint on the buffer, the maximum number of bytes it will use.
Suppressed.EagerBufferConfig	withMaxRecords(long recordLimit)	Set a size constraint on the buffer in terms of the maximum number of keys it will store.

Methods inherited from class org.apache.kafka.streams.kstream.internals.suppress.BufferConfigInternal

emitEarlyWhenFull, shutDownWhenFull, withNoBound

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

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

emitEarlyWhenFull, shutDownWhenFull, withNoBound

Constructor Detail

EagerBufferConfigImpl

public EagerBufferConfigImpl(long maxRecords,
                             long maxBytes)

Method Detail

withMaxRecords

public Suppressed.EagerBufferConfig withMaxRecords(long recordLimit)

Description copied from interface: Suppressed.BufferConfig

Set a size constraint on the buffer in terms of the maximum number of keys it will store.

Specified by:

withMaxRecords in interface Suppressed.BufferConfig<Suppressed.EagerBufferConfig>

withMaxBytes

public Suppressed.EagerBufferConfig withMaxBytes(long byteLimit)

Description copied from interface: Suppressed.BufferConfig

Set a size constraint on the buffer, the maximum number of bytes it will use.

Specified by:

withMaxBytes in interface Suppressed.BufferConfig<Suppressed.EagerBufferConfig>

maxRecords

public long maxRecords()

Specified by:

maxRecords in class BufferConfigInternal<Suppressed.EagerBufferConfig>

maxBytes

public long maxBytes()

Specified by:

maxBytes in class BufferConfigInternal<Suppressed.EagerBufferConfig>

bufferFullStrategy

public BufferFullStrategy bufferFullStrategy()

Specified by:

bufferFullStrategy in class BufferConfigInternal<Suppressed.EagerBufferConfig>

withLoggingDisabled

public Suppressed.EagerBufferConfig withLoggingDisabled()

Description copied from interface: Suppressed.BufferConfig

Disable the changelog for this suppression's internal buffer. This will turn off fault-tolerance for the suppression, and will result in data loss in the event of a rebalance. By default the changelog is enabled.

Specified by:

withLoggingDisabled in interface Suppressed.BufferConfig<Suppressed.EagerBufferConfig>

Returns:

this

withLoggingEnabled

public Suppressed.EagerBufferConfig withLoggingEnabled(Map<String,String> config)

Description copied from interface: Suppressed.BufferConfig

Indicates that a changelog topic should be created containing the currently suppressed records. Due to the short-lived nature of records in this topic it is likely more compactable than changelog topics for KTables.

Specified by:

withLoggingEnabled in interface Suppressed.BufferConfig<Suppressed.EagerBufferConfig>

Parameters:

config - Configs that should be applied to the changelog. Note: Any unrecognized configs will be ignored.

Returns:

this

isLoggingEnabled

public boolean isLoggingEnabled()

Specified by:

isLoggingEnabled in class BufferConfigInternal<Suppressed.EagerBufferConfig>

getLogConfig

public Map<String,String> getLogConfig()

Specified by:

getLogConfig in class BufferConfigInternal<Suppressed.EagerBufferConfig>

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object