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