在 Producer 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]的内容，因为Topic T1上的消息大小更多。 我们是否在 Reactive Kafka 或 Project Reactor 中提供类似 RoutingKafkaTemplate 的支持，我们可以根据主题需要修改生产者配置？

Answer 1

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