Class SuppressedInternal<K>

  • All Implemented Interfaces:
    Suppressed<K>

    public class SuppressedInternal<K>
    extends java.lang.Object
    implements Suppressed<K>
    • 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 interface Suppressed<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 class java.lang.Object
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object