Spring Kafka configuration example to programmatically create a Kafka compact 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 compactTopicExample() {
    return TopicBuilder.name("my-first-compact-kafka-topic")
      .partitions(6)
      .replicas(3)
      .compact()
      .build();
  }
}