在spring boot Kafka中创建通用KafkaTemplate

，需要进行以下步骤：

导入Kafka依赖：在项目的pom.xml文件中，添加Kafka相关的依赖项。可以使用Spring Boot提供的spring-kafka依赖，该依赖已经包含了Kafka的核心库。

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
</dependency>

配置Kafka连接信息：在application.properties或application.yml文件中，配置Kafka的连接信息，包括Kafka服务器地址、端口号等。

spring.kafka.bootstrap-servers=localhost:9092

创建KafkaTemplate Bean：在Spring Boot的配置类中，使用@Bean注解创建一个KafkaTemplate的实例，并配置相关属性。

import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.core.KafkaAdmin;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.kafka.core.DefaultKafkaProducerFactory;
import org.springframework.kafka.core.ProducerFactory;

@Configuration
public class KafkaConfig {

    @Bean
    public KafkaTemplate<String, String> kafkaTemplate() {
        return new KafkaTemplate<>(producerFactory());
    }

    @Bean
    public ProducerFactory<String, String> producerFactory() {
        return new DefaultKafkaProducerFactory<>(producerConfigs());
    }

    // 配置Kafka生产者属性
    @Bean
    public Map<String, Object> producerConfigs() {
        Map<String, Object> props = new HashMap<>();
        props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        return props;
    }
}

使用KafkaTemplate发送消息：在需要发送消息的地方，通过KafkaTemplate的send()方法发送消息。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;

@Component
public class KafkaProducer {

    private final KafkaTemplate<String, String> kafkaTemplate;

    @Autowired
    public KafkaProducer(KafkaTemplate<String, String> kafkaTemplate) {
        this.kafkaTemplate = kafkaTemplate;
    }

    public void sendMessage(String topic, String message) {
        kafkaTemplate.send(topic, message);
    }
}

以上是在Spring Boot Kafka中创建通用KafkaTemplate的步骤。KafkaTemplate是Spring Kafka提供的一个用于发送消息的模板类，封装了Kafka发送消息的细节，提供了简化的API供开发者使用。

应用场景：