我认为这不是Kafka的问题，而是Jackson的问题。
默认情况下，Kafka使用jackson进行序列化/反序列化。你可以注册 JavaTimeModule 对于 ObjectMapper 建造 JsonDeserializer 用它。然后建立您的自定义 ConsumerFactory :

public ConsumerFactory<String, Request> consumerFactory() {

     ObjectMapper objectMapper = new ObjectMapper();
     objectMapper.registerModule(new JavaTimeModule());

     Map<String, Object> config = new HashMap<>();
     config.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);

     StringDeserializer keyDeserializer = new StringDeserializer();
     JsonDeserializer<Request> jsonDeserializer = new JsonDeserializer<>(objectMapper);

     ConsumerFactory<String, Request> factory = new DefaultKafkaConsumerFactory<>(config, keyDeserializer,  jsonDeserializer);
     return factory;
}

您必须将jackson-datatype-jsr310依赖项添加到您的项目中才能使 JavaTimeModule 无障碍。
如果您使用的是spring boot并且希望配置 ObjectMapper 在全球范围内，您可以执行以下操作，例如：

@Configuration
@EnableKafka
public class KafkaConfig {
    @Bean
    public ConsumerFactory<String, Request> consumerFactory(Jackson2ObjectMapperBuilder objectMapperBuilder) {

        Map<String, Object> config = new HashMap<>();
        config.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);

        StringDeserializer keyDeserializer = new StringDeserializer();
        JsonDeserializer<Request> jsonDeserializer = new JsonDeserializer<>(objectMapperBuilder.build());

        ConsumerFactory<String, Request> factory = new DefaultKafkaConsumerFactory<>(config, keyDeserializer,  jsonDeserializer);
        return factory;
    }

    @Bean
    public Jackson2ObjectMapperBuilder objectMapperBuilder() {
        Jackson2ObjectMapperBuilder builder = new Jackson2ObjectMapperBuilder();
        builder.modulesToInstall(new JavaTimeModule());
        return builder;
    }
}

这解决了问题！我在我的字段声明中使用了下面的注解。

@JsonDeserialize(using = LocalDateDeserializer.class)
@JsonSerialize(using = LocalDateSerializer.class)