我正在创建一个与另一个服务对话的服务，以确定要收听的kafka主题。kafka话题可能有不同的密钥和值类型。因此，我想为每个配置(主题、密钥类型、值类型(动态地创建不同的kafka使用者，其中这些配置仅在运行时已知。然而，在春季kafka中，我看不到动态传递所有这些参数的方法(至少我不知道(。我该怎么做呢。
只需在运行时创建一个新的侦听器容器。
https://docs.spring.io/spring-kafka/docs/current/reference/html/#message-侦听器容器
如果您使用的是Spring Boot，您可以使用它自动配置的ConcurrentKafkaListenerContainerFactory；如果没有，只需手动创建和初始化容器。