什么是Spring的Apache Kafka的监听器容器？

Question

我明白，要使一个方法成为Kafka消息侦听器的目标，我必须用@KafkaListener注释标记这个方法。此注释允许通过containerFactory元素指定KafkaListenerContainerFactory。

下面是巴尔东SpringKafka教程的一些片段。

Kafka消费者配置。JAVA

private ConsumerFactory<String, String> consumerFactory(String groupId) {
    Map<String, Object> props = new HashMap<>();
    ...
    return new DefaultKafkaConsumerFactory<>(props);
}

private ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory(String groupId) {
    ConcurrentKafkaListenerContainerFactory<String, String> factory =
            new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConsumerFactory(consumerFactory(groupId));
    return factory;
}

@Bean
public ConcurrentKafkaListenerContainerFactory<String, String> fooKafkaListenerContainerFactory() {
    return kafkaListenerContainerFactory("foo");
}

MessageListener。JAVA

@KafkaListener(
    topics = "${message.topic.name}", 
    groupId = "foo", 
    containerFactory = "fooKafkaListenerContainerFactory")
public void listenGroupFoo(String message) {
    System.out.println("Received Message in group 'foo': " + message);
    ...
}

我不明白的是为什么我们需要一个监听器容器工厂。什么是侦听器容器？当一个方法被这样注释时会发生什么？

Answer 1

侦听器“容器”是跨越多种技术（JMS、RabbitMQ、Kafka、AWS等）的Spring概念。

侦听器被定义为POJO bean方法，是容器的属性（容器“包含”侦听器）。

容器负责与代理进行交互，以接收消息，并根据侦听器类型对每条消息或一批消息调用侦听器方法。

这意味着您的应用程序代码不必处理与代理交互的机制，您可以只关注业务逻辑。

框架会发现任何@KafkaListener方法，并使用工厂为每个方法创建一个容器。