spring kafka 入站和出站映射头不同

Question

我们正在使用 spring-kafka，对于与我们通信但未设置 spring_json_header_types 标头的非 spring 应用程序，我们指定某些标头应通过将它们添加为 rawMappedHeaders 来映射为字符串。我们通过设置配置为所有活页夹执行此操作： spring.cloud.stream.kafka.binder.headerMapperBeanName 作为我们为其设置 rawMappedHeaders 的默认KafkaHeaderMapper。这适用于我们拥有的生产者和消费者绑定。

然而，当我们向某些 Spring 应用程序发送出站数据时，我们实际上不想遗漏这些 rawMappedHeader 字段的 spring_json_header_types 值，因为下游应用程序尚未适应这种非 Spring 应用程序通信。

有没有一种方法可以通过配置或代码将 headerMapperBeanName 仅应用于所有生产者或仅应用于所有消费者，以便我可以让它们以不同的方式映射出站和入站标头？或者有没有更好的方法来做到这一点，DefaultKafkaHeaderMapper 本身可以处理？

Answer 1

绑定器级别只有一个标头映射器。

创建一个自定义的 KafkaHeaderMapper 实现可能是最简单的，该实现委托给不同的 DefaultKafkaHeaderMapper 来进行入站和出站映射。

public interface KafkaHeaderMapper {

    /**
     * Map from the given {@link MessageHeaders} to the specified target headers.
     * @param headers the abstracted MessageHeaders.
     * @param target the native target headers.
     */
    void fromHeaders(MessageHeaders headers, Headers target);

    /**
     * Map from the given native headers to a map of headers for the eventual
     * {@link MessageHeaders}.
     * @param source the native headers.
     * @param target the target headers.
     */
    void toHeaders(Headers source, Map<String, Object> target);

}