在生产者 Spring Reactive Kafka 中使用多个主题配置

Question

我是 Kafka 新手，我们在应用程序中使用 Spring Web Flux。我们需要将两个不同的消息推送到两个不同的主题，比如 T1 和 T2。卡夫卡经纪人是一样的。 我们正在使用 ReactiveKafkaProducerTemplate，它运行良好。

    @Bean
    public ReactiveKafkaProducerTemplate<String, Object> reactiveKafkaProducerTemplate(
            KafkaProperties properties) {
        final Map<String, Object> props = properties.buildProducerProperties();
        return new ReactiveKafkaProducerTemplate<String, Object>(SenderOptions.create(props));
    }

现在我们需要仅压缩一个 Topic[T1] 内容，因为主题 T1 上的消息大小更大。 我们在 Reactive Kafka 或 Project Reactor 中是否有类似 RoutingKafkaTemplate 的支持，我们可以在其中根据主题需要修改生产者配置？

Answer 1

没有；没有等价物；您需要配置两个具有不同生产者配置的模板。