我正在创建一个与另一个服务通信的服务，以便识别要收听的 kafka 主题。 kafka主题可能有不同的键和值类型。因此，我想为每个配置（主题、键类型、值类型）动态创建不同的 kafka 消费者，其中配置仅在运行时已知。然而在 spring kafka 中，我没有看到动态传递所有这些参数的方法（至少我不知道）。我应该如何继续这件事。
只需在运行时创建一个新的侦听器容器即可。
https://docs.spring.io/spring-kafka/docs/current/reference/html/#message-listener-container https://docs.spring.io/spring-kafka/docs/current/reference/html/#message-listener-container
如果您使用 Spring Boot，则可以使用ConcurrentKafkaListenerContainerFactory它会自动配置；如果没有，只需手动创建并初始化容器。
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
