几天以来,我一直在尝试将主题动态传递给 Kafka 侦听器的方法,而不是通过 Java DSL 中的键使用它们。周围有人以前做过这件事,或者可以阐明实现这一目标的最佳方法是什么?
我发现最简单的解决方案是使用 SpEL:
@Autowired
private SomeBean kafkaTopicNameProvider;
@KafkaListener(topics = "#{kafkaTopicNameProvider.provideName()}")
public void listener() { ... }
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)