在Producer Spring Reactive Kafka上使用多主题配置

Question

我是Kafka的新用户，我们在应用程序中使用了Spring Web Flux。我们需要向两个不同的主题推送两个不同的消息，比如T1和T2。Kafka经纪人也是一样。我们正在使用ReactiveKafkaProducerTemplate，效果很好。

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

现在我们只需要单独压缩一个主题[T1]内容，因为消息大小在主题T1上更大。我们是否在响应式Kafka或Project Actor中支持路由KafkaTemplate，我们可以根据主题需要修改生产者配置？

Answer 1

没有；没有等效的；您需要使用不同的生产者配置配置两个模板。