Class WindowedChangelogTopicConfig


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

      • getProperties

        public Map<String,​String> getProperties​(Map<String,​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
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object