在 Spring Cloud Stream 中获取底层底层的 Kafka 消费者和生产者

Question

我有一个用例，我想在 Spring Cloud Stream 应用程序中获取底层 Kafka 生产者 (KafkaTemplate)。在浏览代码时，我偶然发现了KafkaProducerMessageHandler，它有一个getKafkaTemplate 方法。但是，它无法自动接线。

另外，如果我直接自动连接KafkaTemplate，模板会使用默认属性进行初始化，它会忽略 SCSt 配置的binder 键中的broker

如何在 Spring Cloud Stream 应用程序中访问底层 KafkaTemplate 或生产者/消费者？

编辑：实际上我的 SCSt 应用程序有多个 Kafka 活页夹，我想获得与每个活页夹对应的 KafkaTemplate 或 Kafka 生产者。这有可能吗？

Answer 1

尚不完全清楚您为什么需要这样做，但您可以通过将 ProducerMessageHandlerCustomizer @Bean 添加到应用程序上下文来捕获 KafkaTemplates。