Spring Kafka topic configuration. Override partitions for existing topic

KafkaTopicConfiguration.java

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 topicExample() {
    return TopicBuilder.name("already-existing-kafka-topic")
      .partitions(6)
      .build();
  }
}