我有一个用例,希望在spring云流应用程序中获得底层的kafka生产者(kafkatemplate)。在浏览代码时我偶然发现 KafkaProducerMessageHandler
它有一个 getKafkaTemplate
方法。但是,它不能自动布线。
另外,如果我直接自动连线 KafkaTemplate
,则模板将使用默认属性初始化,并忽略 broker
在 binder
scst配置的密钥
如何在spring云流应用程序中访问底层kafkatemplate或生产者/消费者?
编辑:实际上我的scst应用程序有多个Kafka活页夹,我想得到 KafkaTemplate
或Kafka生产商对应的每一个活页夹。有可能吗?
1条答案
按热度按时间aurhwmvo1#
现在还不完全清楚你为什么要这么做,但是你可以捕捉到
KafkaTemplate
通过添加ProducerMessageHandlerCustomizer
@Bean
应用程序上下文。