Uses of Class
org.springframework.kafka.config.TopicBuilder
-
Uses of TopicBuilder in org.springframework.kafka.config
Modifier and TypeMethodDescriptionTopicBuilder.assignReplicas
(int partition, List<Integer> replicaList) Add an individual replica assignment.TopicBuilder.compact()
Set theTopicConfig.CLEANUP_POLICY_CONFIG
toTopicConfig.CLEANUP_POLICY_COMPACT
.Set a configuration option.Set the configs.static TopicBuilder
Create a TopicBuilder with the supplied name.TopicBuilder.partitions
(int partitionCount) Set the number of partitions (default broker 'num.partitions').TopicBuilder.replicas
(int replicaCount) Set the number of replicas (default broker 'default.replication.factor').TopicBuilder.replicasAssignments
(Map<Integer, List<Integer>> replicaAssignments) Set the replica assignments.