Spring kafka 2.2类型映射类加载器不匹配

Question

我正在尝试使用Spring Kafka2.2中引入的新类型映射特性：

向下滚动到“映射类型”:
https://docs.spring.io/spring-kafka/reference/htmlsingle/#serdes

在生产者方面，我注册了一个映射，如下所示：

senderProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);
senderProps.put(JsonSerializer.TYPE_MAPPINGS, "foo:com.myfoo.Foo");

consumerProps.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, JsonDeserializer.class);
consumerProps.put(JsonDeSerializer.TYPE_MAPPINGS, "foo:com.yourfoo.Foo");

我在《Spring-Kafka》中把问题缩小到这个方法：

https://github.com/spring-projects/spring-kafka/blob/master/spring-kafka/src/main/java/org/springframework/kafka/support/converter/abstractJavaTypeMapper.java#L142

protected void addHeader(Headers headers, String headerName, Class<?> clazz) {
    if (this.classIdMapping.containsKey(clazz)) {
        headers.add(new RecordHeader(headerName, this.classIdMapping.get(clazz)));
    }
    else {
        headers.add(new RecordHeader(headerName, clazz.getName().getBytes(StandardCharsets.UTF_8)));
    }
}

当通过执行kafka记录的序列化进行调试时，执行实际上会转到else分支，而根据我的理解，它实际上应该转到if分支并添加foo作为头。相反，它将com.myfoo.foo添加到头部。

罪魁祸首似乎与类加载器不匹配有关，但我不确定这实际上是一个bug还是我在我的端做了什么蠢事。

基本上，classidmapping映射以com.myfoo.foo作为键和foo的UTF-8 byte[]表示形式作为相应的值正确填充。

但是，在if检查期间，clazz参数是一个由不同的类加载器加载的类，与存储在classidmapping映射中的类一样，因此哈希代码是不同的，它会转到else分支。

实际上是String-Kafka端的bug还是我配置错误了？

谢谢

Answer 1

这看起来确实像是我们在实现中的一个疏漏。请为Apache Kafka项目的Spring提出一个问题：https://github.com/spring-projects/spring-kafka。我们的想法是不使用Class<？>进行映射，而是使用它的完全限定类名。

看起来你的应用程序是多类加载器，例如它是Web One。Apache Kafka客户机将senderprops.put(Producerconfig.value_serializer_class_config,jsonserializer.class)；加载到其类加载器中，同时所有其他操作都由应用程序上下文类加载器完成。

作为一种解决方法，我们在解决该问题的同时，建议使用DefaultKafkaProducerFactory配置及其SetValueSerializer()来填充JSONSerializerbean引用。这样，您需要通过其setTypeMapper()填充类映射，因此需要在DefaultJackson2JavaTypeMapper上填充一个SetIDClassMapping()。