public static final class SbkTopicUtils.SbkTopicConfigBuilder
extends java.lang.Object
Constructor and Description |
---|
SbkTopicConfigBuilder() |
Modifier and Type | Method and Description |
---|---|
SbkTopicUtils.SbkTopicConfig |
build() |
SbkTopicUtils.SbkTopicConfigBuilder |
setCleanupPolicy(java.lang.String cleanupPolicy) |
SbkTopicUtils.SbkTopicConfigBuilder |
setMinRetentionTimeMs(long minRetentionTimeMs) |
SbkTopicUtils.SbkTopicConfigBuilder |
setPartitionCount(int partitionCount) |
SbkTopicUtils.SbkTopicConfigBuilder |
setPartitionCount(java.util.Map<java.lang.String,?> config,
java.lang.String partitionCountConfig,
int defaultPartitionCount) |
SbkTopicUtils.SbkTopicConfigBuilder |
setReplicationFactor(java.util.Map<java.lang.String,?> config,
java.lang.String replicationFactorConfig,
short defaultReplicationFactor) |
SbkTopicUtils.SbkTopicConfigBuilder |
setTopic(java.lang.String topic) |
public SbkTopicUtils.SbkTopicConfig build()
public SbkTopicUtils.SbkTopicConfigBuilder setMinRetentionTimeMs(long minRetentionTimeMs)
public SbkTopicUtils.SbkTopicConfigBuilder setReplicationFactor(java.util.Map<java.lang.String,?> config, java.lang.String replicationFactorConfig, short defaultReplicationFactor)
public SbkTopicUtils.SbkTopicConfigBuilder setTopic(java.lang.String topic)
public SbkTopicUtils.SbkTopicConfigBuilder setPartitionCount(java.util.Map<java.lang.String,?> config, java.lang.String partitionCountConfig, int defaultPartitionCount)
public SbkTopicUtils.SbkTopicConfigBuilder setPartitionCount(int partitionCount)
public SbkTopicUtils.SbkTopicConfigBuilder setCleanupPolicy(java.lang.String cleanupPolicy)