在springcloudstream中获取底层的kafka消费者和生产者

ijnw1ujt  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(258)

我有一个用例,希望在spring云流应用程序中获得底层的kafka生产者(kafkatemplate)。在浏览代码时我偶然发现 KafkaProducerMessageHandler 它有一个 getKafkaTemplate 方法。但是,它不能自动布线。
另外,如果我直接自动连线 KafkaTemplate ,则模板将使用默认属性初始化,并忽略 brokerbinder scst配置的密钥
如何在spring云流应用程序中访问底层kafkatemplate或生产者/消费者?
编辑:实际上我的scst应用程序有多个Kafka活页夹,我想得到 KafkaTemplate 或Kafka生产商对应的每一个活页夹。有可能吗?

aurhwmvo

aurhwmvo1#

现在还不完全清楚你为什么要这么做,但是你可以捕捉到 KafkaTemplate 通过添加
ProducerMessageHandlerCustomizer @Bean 应用程序上下文。

相关问题