public class UnwindowedChangelogTopicConfig extends InternalTopicConfig
Constructor and Description |
---|
UnwindowedChangelogTopicConfig(java.lang.String name,
java.util.Map<java.lang.String,java.lang.String> topicConfigs) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(java.lang.Object o) |
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.
|
int |
hashCode() |
java.lang.String |
toString() |
name, numberOfPartitions
public UnwindowedChangelogTopicConfig(java.lang.String name, java.util.Map<java.lang.String,java.lang.String> topicConfigs)
public java.util.Map<java.lang.String,java.lang.String> getProperties(java.util.Map<java.lang.String,java.lang.String> defaultProperties, long additionalRetentionMs)
getProperties
in class InternalTopicConfig
additionalRetentionMs
- - added to retention to allow for clock drift etcpublic boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public java.lang.String toString()
toString
in class InternalTopicConfig