Springboot 2.x配置kafka 2.2.0

要在Spring Boot 2.x中配置Kafka 2.2.0，首先需要在项目的pom.xml文件中添加相应的依赖项。在这个例子中，我们将使用Spring Kafka来与Kafka集成：

<!-- Spring Kafka -->
<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
    <version>2.2.0.RELEASE</version>
</dependency>

添加了依赖项后，可以在Spring Boot应用程序的配置文件（application.properties或application.yml）中配置Kafka连接和相关属性。下面是一个示例的application.properties文件配置：

# Kafka连接配置
spring.kafka.bootstrap-servers=localhost:9092

# 消费者配置
spring.kafka.consumer.group-id=my-group
spring.kafka.consumer.auto-offset-reset=earliest

# 生产者配置
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer

以上配置示例设置了Kafka的连接地址为localhost:9092，并指定了消费者和生产者的相关配置。你可以根据需要进行修改。

接下来，你可以创建Kafka消费者和生产者的相关类。这些类可以使用Spring Kafka提供的注解和模板来简化Kafka操作。下面是一个示例的Kafka消费者类：

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class KafkaConsumer {
    
    @KafkaListener(topics = "my-topic", groupId = "my-group")
    public void consume(String message) {
        // 处理接收到的消息
        System.out.println("Received message: " + message);
    }
}

上面示例中的Kafka消费者使用了`@KafkaListener`注解来监听名为"my-topic"的Kafka主题，并将接收到的消息作为字符串进行处理。

类似地，你可以创建一个Kafka生产者类来发送消息。下面是一个示例的Kafka生产者类：

import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Component;

@Component
public class KafkaProducer {
    private final KafkaTemplate<String, String> kafkaTemplate;

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

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

上面示例中的Kafka生产者使用了`KafkaTemplate`来发送消息。

现在，你已经配置了Kafka并创建了消费者和生产者类。你可以在其他的Spring Boot组件中使用这些类来实现Kafka的消费和生产操作。

请注意，这只是一个简单的示例，实际使用中可能需要更多的配置和自定义。你可以根据具体需求在项目中添加额外的配置和逻辑。