Spring Boot应用中配置连接到Kafka集群中的单一节点

在Spring Boot应用程序中配置连接到Kafka集群中的单个节点通常涉及到以下几个步骤：

1. 添加依赖：首先，你需要在`pom.xml`文件中添加Spring Cloud Stream Kafka和相关的Spring Kafka依赖，例如：

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

2. 配置application.yml（或application.properties）：
- `spring.cloud.stream.bindings.input.destination`: 指定消息应发送到的Kafka主题名。
- `spring.cloud.stream.kafka.binder.brokers`: 设置Kafka服务器地址，例如：

   spring:
     cloud:
       stream:
         kafka:
           binder:
             brokers: 'localhost:9092'

如果是生产环境，你应该替换为实际的Kafka集群IP和端口。

3. 创建消费者或生产者：使用`@StreamListener`或`@KafkaListener`注解创建一个监听消息的类，用于消费主题上的数据，或者使用`@SendTo`和`@KafkaTemplate`注解创建一个生产者类，用于向主题发送数据。

4. 集群模式下的配置：如果你的应用需要连接到集群中的多个节点，可以在`bootstrap.servers`属性中指定多个地址，如 `localhost:9092,other-node-1:9092,other-node-2:9092`。