Class WindowedChangelogTopicConfig


  • public class WindowedChangelogTopicConfig
    extends InternalTopicConfig
    WindowedChangelogTopicConfig captures the properties required for configuring the windowed store changelog topics.
    • Method Detail

      • getProperties

        public java.util.Map<java.lang.String,​java.lang.String> getProperties​(java.util.Map<java.lang.String,​java.lang.String> defaultProperties,
                                                                                    long additionalRetentionMs)
        Get the configured properties for this topic. If retentionMs is set then we add additionalRetentionMs to work out the desired retention when cleanup.policy=compact,delete
        Specified by:
        getProperties in class InternalTopicConfig
        Parameters:
        additionalRetentionMs - - added to retention to allow for clock drift etc
        Returns:
        Properties to be used when creating the topic
      • 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