Skip to content

Instantly share code, notes, and snippets.

@j-tim
Created April 10, 2020 12:18
Show Gist options
  • Save j-tim/040d825e2f111adc54beb0b2484c0cef to your computer and use it in GitHub Desktop.
Save j-tim/040d825e2f111adc54beb0b2484c0cef to your computer and use it in GitHub Desktop.
Spring Kafka configuration example to programmatically create a Kafka topic with 3 replicas
package io.stockgeeks.kafka.config;
import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.config.TopicBuilder;
@Configuration
public class KafkaTopicConfiguration {
@Bean
public NewTopic topicWith3Replicas() {
return TopicBuilder.name("my-very-cool-topic")
.replicas(3)
.build();
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment