Spring Kafka configuration example of passing specific Kafka topic configuration properties (in this case to configure compression)

KafkaTopicConfiguration.java

import org.apache.kafka.clients.admin.NewTopic;
import org.apache.kafka.common.config.TopicConfig;
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 topicWithCompressionExample() {
    return TopicBuilder.name("kafka-topic-with-compression")
      .partitions(6)
      .replicas(3)
      .config(TopicConfig.COMPRESSION_TYPE_CONFIG, "zstd")
      .build();
  }
}