Class InternalTopicConfig

    • Method Detail

      • getProperties

        public abstract 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
        Parameters:
        additionalRetentionMs - - added to retention to allow for clock drift etc
        Returns:
        Properties to be used when creating the topic
      • hasEnforcedNumberOfPartitions

        public boolean hasEnforcedNumberOfPartitions()
      • name

        public java.lang.String name()
      • numberOfPartitions

        public java.util.Optional<java.lang.Integer> numberOfPartitions()
      • setNumberOfPartitions

        public void setNumberOfPartitions​(int numberOfPartitions)
      • toString

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