springboot kafka配置类

springboot中的Kafka配置类可以使用@Configuration注解来标，并通过@Bean注解来创建相关的bean。下面是一个示例的Kafka配置类：

import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class KafkaConfig {
    
    @Value("${spring.kafka.topic}")
    private String topic;
    
    @Value("${spring.kafka.bootstrap-servers}")
    private String bootstrapServers;
    
    @Bean
    public NewTopic createTopic() {
        return new NewTopic(topic, 1, (short) 1);
    }
    
    // 其他的Kafka配置方法
    
}

在这个例子中，通过@Configuration注解将类标识为配置类，然后使用@Bean注解创建了一个名为createTopic的bean，用于创建Kafka主题。在注解上使用@Value可以获取到配置文件中的值，例如用于设置主题名称和Kafka的引导服务器。你也可以在这个配置类中添加其他的Kafka相关配置方法。