spring-integration-kafka：KafkaTemplate#setMessageConverter(RecordMessageConverter) 没有效果

Question

我正在尝试为我的 Spring Integration Kafka 消息处理程序设置一个自定义消息转换器（是的，我知道我可以提供序列化程序配置 - 我正在尝试做一些不同的事情。

我有以下几点：

@Bean
public KafkaTemplate<String, String> kafkaTemplate() {
    final KafkaTemplate<String, String> kafkaTemplate = new KafkaTemplate<>(producerFactory());
    kafkaTemplate.setMessageConverter(new MessagingMessageConverter() {
        @Override
        public ProducerRecord<?, ?> fromMessage(final Message<?> message, final String s) {
            LOGGER.info("fromMessage({}, {})", message, s);
            return super.fromMessage(message, s);
        }
    });
    return kafkaTemplate;
}

@Bean
@ServiceActivator(inputChannel = "kafkaMessageChannel")
public MessageHandler kafkaMessageHandler() {
    final KafkaProducerMessageHandler<String, String> handler = new KafkaProducerMessageHandler<>(kafkaTemplate());
    handler.setTopicExpression(new LiteralExpression(getTopic()));
    handler.setSendSuccessChannel(kafkaSuccessChannel());
    return handler;
}

当消息发送到kafkaMessageChannel 时，处理程序发送它并且结果显示在kafkaSuccessChannel 中，但是我在模板中设置的RecordMessageConverter 从未被调用

Answer 1

模板消息转换器仅在使用出站通道适配器不使用的template.send(Message<?>) 时使用。

出站适配器使用其标头映射器映射标头本身；没有对消息负载执行转换。

哪些文档让您相信转换器是在这种情况下使用的？