Class SuppressedInternal<K>
- java.lang.Object
-
- org.apache.kafka.streams.kstream.internals.suppress.SuppressedInternal<K>
-
- All Implemented Interfaces:
Suppressed<K>
public class SuppressedInternal<K> extends java.lang.Object implements Suppressed<K>
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.kafka.streams.kstream.Suppressed
Suppressed.BufferConfig<BC extends Suppressed.BufferConfig<BC>>, Suppressed.StrictBufferConfig
-
-
Constructor Summary
Constructors Constructor Description SuppressedInternal(java.lang.String name, java.time.Duration suppressionTime, Suppressed.BufferConfig bufferConfig, org.apache.kafka.streams.kstream.internals.suppress.TimeDefinitions.TimeDefinition<K> timeDefinition, boolean suppressTombstones)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(java.lang.Object o)
int
hashCode()
java.lang.String
name()
java.lang.String
toString()
Suppressed<K>
withName(java.lang.String name)
Use the specified name for the suppression node in the topology.
-
-
-
Constructor Detail
-
SuppressedInternal
public SuppressedInternal(java.lang.String name, java.time.Duration suppressionTime, Suppressed.BufferConfig bufferConfig, org.apache.kafka.streams.kstream.internals.suppress.TimeDefinitions.TimeDefinition<K> timeDefinition, boolean suppressTombstones)
-
-
Method Detail
-
withName
public Suppressed<K> withName(java.lang.String name)
Description copied from interface:Suppressed
Use the specified name for the suppression node in the topology.This can be used to insert a suppression without changing the rest of the topology names (and therefore not requiring an application reset).
Note however, that once a suppression has buffered some records, removing it from the topology would cause the loss of those records.
A suppression can be "disabled" with the configuration
untilTimeLimit(Duration.ZERO, ...
.- Specified by:
withName
in interfaceSuppressed<K>
- Parameters:
name
- The name to be used for the suppression node and changelog topic- Returns:
- The same configuration with the addition of the given
name
.
-
name
public java.lang.String name()
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equals
in classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-