如何移除Kafka（Spring靴）中的标题？

Question

我需要向Kafka的特定主题发送消息。我使用以下KafkaTemplate来实现这一点：KafkaTemplate

以下参数放在Kafka生产者中：

private ProducerFactory<String, RequestDto> producerConfigs() {
    Map<String, Object> props = new HashMap<>();
    props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaServer);
    props.put(ProducerConfig.CLIENT_ID_CONFIG, clientId);
    props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
    props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);
    return new DefaultKafkaProducerFactory<>(props);
}

创建生产者：

    public KafkaTemplate<String, RequestDto> kafkaTemplate() {
        KafkaTemplate<String, RequestDto> template = new KafkaTemplate<>(producerConfigs());
        template.setMessageConverter(new StringJsonMessageConverter());
        return template;
    }

当我执行“发送”方法时，我有一条消息发送到Kafka主题，但同时我发送了标头，其中包含请求的DTO文件的路径。

ListenableFuture<SendResult<String, RequestDto>> result = kafkaTemplate.send(topic, requestDto);

偏移资源管理器中的示例标头

由于这个标题，应用程序中出现了一些问题，这是一个消费者，我对此无能为力。有没有办法从查询中删除此标题？

Answer 1

您可以通过添加带有ADD_TYPE_INFO_HEADERSfalse的JsonSerializer来创建DefaultKafkaProducerFactory

JsonSerializer jsonSerializer = new JsonSerializer();
jsonSerializer.setAddTypeInfo​(false);  //  

设置为false以禁用添加类型信息标头。

然后使用键和值序列化器创建DefaultKafkaProducerFactory

return new DefaultKafkaProducerFactory<>(props,new StringSerializer(),jsonSerializer);

您还可以通过producer-side-by-Configuration属性禁用此属性

ADD_TYPE_INFO_HEADERS（默认为true）：您可以将其设置为false以在JsonSerializer上禁用此功能（设置addTypeInfo属性）。

在消费者方面忽略

USE_TYPE_INFO_HEADERS（默认为true）：您可以将其设置为false以忽略序列化程序设置的标头。