Kafka模板连接与broker的问题

1. 首先，在pom.xml文件中添加以下依赖项：

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

2. 在application.properties文件中配置Kafka broker的地址：

spring.kafka.bootstrap-servers=localhost:9092

3. 在Spring Boot应用程序中创建Kafka Template bean，并设置其属性：

import org.springframework.context.annotation.Bean;
import org.springframework.kafka.core.KafkaTemplate;

public class KafkaConfig {

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

    @Bean
    public ProducerFactory<String, String> producerFactory() {
        Map<String, Object> configProps = new HashMap<>();
        configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        return new DefaultKafkaProducerFactory<>(configProps);
    }

}

4. 然后，在需要使用Kafka Template的类中注入它，可以像下面这样调用Kafka Template发送消息：

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

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