spring-kafka 注解 @KafkaListener 放在方法上和类上有什么不同

将 @KafkaListener 注解放在类上表示该类中的所有方法都是 Kafka 消息监听器，可以通过设置不同的 topic 来订阅不同的消息。将 @KafkaListener 注解放在方法上表示该方法是 Kafka 消息监听器，可以通过设置不同的 topic 来订阅不同的消息。在类上使用注解可以方便地管理多个监听器，而在方法上使用注解可以更细粒度地控制消息的处理。

相关问题

需要使用 spring-kafka 中的 KafkaListener 注解的使用方式

使用 KafkaListener 注解可以让 Spring Boot 应用轻松地消费 Kafka 消息。

步骤如下：

1. 引入 spring-kafka 依赖。

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

2. 在 Spring Boot 应用的配置文件中配置 Kafka 生产者和消费者的相关信息。

spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.group-id=my-group
spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer

3. 创建一个 Kafka 消费者，定义一个方法用于处理消息。

@Component
public class KafkaConsumer {

    @KafkaListener(topics = "my-topic", groupId = "my-group")
    public void receive(String message) {
        System.out.println("Received message: " + message);
    }

}

4. 创建一个 Kafka 生产者，发送消息。

@Component
public class KafkaProducer {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    public void send(String message) {
        kafkaTemplate.send("my-topic", message);
    }

}

5. 在任何需要发送消息的地方注入 KafkaProducer，调用 send 方法发送消息即可。

@Autowired
private KafkaProducer kafkaProducer;

public void sendMessage() {
    kafkaProducer.send("hello, kafka");
}

以上就是使用 spring-kafka 中的 KafkaListener 注解的基本使用方式。

spring-kafka整合

Spring-Kafka整合是将Spring框架与Kafka消息系统进行整合，使得开发者能够方便地使用Spring框架进行Kafka消息的生产和消费。

Spring-Kafka整合提供了以下功能：

1. 自动配置Kafka生产者和消费者。

2. 提供KafkaTemplate用于发送消息。

3. 提供@KafkaListener注解用于监听Kafka主题。

4. 提供KafkaListenerContainerFactory用于创建Kafka监听器容器。

5. 提供KafkaAdmin用于管理Kafka集群。

Spring-Kafka整合的使用步骤如下：

1. 添加Spring-Kafka依赖

在pom.xml文件中添加以下依赖：

<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
    <version>${spring-kafka.version}</version>
</dependency>

2. 配置Kafka连接

在application.properties文件中添加Kafka连接相关配置：

spring.kafka.bootstrap-servers=localhost:9092

3. 编写Kafka生产者

使用KafkaTemplate发送消息：

@Autowired
private KafkaTemplate<String, String> kafkaTemplate;

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

4. 编写Kafka消费者

使用@KafkaListener注解监听Kafka主题：

@KafkaListener(topics = "test-topic")
public void receiveMessage(String message) {
    //消费消息
}

5. 配置Kafka监听器容器

使用KafkaListenerContainerFactory创建Kafka监听器容器：

@Bean
public KafkaListenerContainerFactory<?> kafkaListenerContainerFactory() {
    ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConsumerFactory(consumerFactory());
    factory.setConcurrency(1);
    factory.getContainerProperties().setPollTimeout(3000);
    return factory;
}

6. 配置Kafka管理器

使用KafkaAdmin创建Kafka管理器：

@Bean
public KafkaAdmin kafkaAdmin() {
    Map<String, Object> configs = new HashMap<>();
    configs.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
    return new KafkaAdmin(configs);
}

Spring-Kafka整合的使用可以使得开发者更加方便地使用Kafka消息系统，提高消息的生产和消费效率。