Package | Description |
---|---|
io.simplesource.saga.shared.topics |
Modifier and Type | Method and Description |
---|---|
TopicConfigBuilder |
TopicConfigBuilder.BuildSteps.applyStep(TopicConfigBuilder builder) |
TopicConfigBuilder |
TopicConfigBuilder.withDefaultTopicSpec(int partitions,
int replication,
int retentionInDays)
Sets the topic spec by default topic to be the topic spec with the specified partitions and replication factor, as well as the setting the topic retention
|
TopicConfigBuilder |
TopicConfigBuilder.withNamingStrategy(io.simplesource.kafka.api.ResourceNamingStrategy namingStrategy)
Sets the the resource naming strategy for topic creation
|
TopicConfigBuilder |
TopicConfigBuilder.withTopicBaseName(String topicBaseName)
Sets the base name for topic creation when applying the prefix resource naming strategy
|
TopicConfigBuilder |
TopicConfigBuilder.withTopicNameOverride(String topicType,
String topicName)
Overrides the topic name for a given topic type
|
TopicConfigBuilder |
TopicConfigBuilder.withTopicNamer(TopicNamer topicNamer)
Explicitly sets the topic namer
|
TopicConfigBuilder |
TopicConfigBuilder.withTopicPrefix(String prefix)
Sets the resource naming strategy to
PrefixResourceNamingStrategy with the given prefix |
TopicConfigBuilder |
TopicConfigBuilder.withTopicSpecOverride(String topicType,
io.simplesource.kafka.spec.TopicSpec topicSpec)
Overrides the topic spec for a given topic type
|
Modifier and Type | Method and Description |
---|---|
TopicConfigBuilder |
TopicConfigBuilder.BuildSteps.applyStep(TopicConfigBuilder builder) |
Copyright © 2019. All rights reserved.