打造消费者动态春天卡夫卡 [英] Create consumer dynamically spring kafka

问题描述

我正在创建一个与另一个服务对话的服务，以确定要收听的卡夫卡主题。卡夫卡主题可能有不同的键和值类型。因此，我希望为每个配置(主题、键类型、值类型)动态创建不同的Kafka消费者，其中配置仅在运行时才知道。然而，在春季的Kafka中，我看不到动态传递所有这些参数的方法(至少我不知道有)。我应该如何进行这项工作。

推荐答案

只需在运行时创建新的侦听器容器。

https://docs.spring.io/spring-kafka/docs/current/reference/html/#message-listener-container

如果您使用的是Spring Boot，您可以使用它自动配置的ConcurrentKafkaListenerContainerFactory；如果不是，只需手动创建和初始化容器。

这篇关于打造消费者动态春天卡夫卡的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！