Kafka自定义反序列化程序转换为Java对象

Question

我正在使用Spring Kafka集成，我有自己的值通用序列化器/反序列化器，如下所示

序列化程序:

public class KafkaSerializer<T> implements Serializer<T> {

  private ObjectMapper mapper;

  @Override
  public void close() {
  }

  @Override
  public void configure(final Map<String, ?> settings, final boolean isKey) {
    mapper = new ObjectMapper();
  }

  @Override
  public byte[] serialize(final String topic, final T object) {
    try {
      return mapper.writeValueAsBytes(object);
    } catch (final JsonProcessingException e) {
      throw new IllegalArgumentException(e);
    }
  }
}

反序列化程序:

public class KafkaDeserializer<T> implements Deserializer<T> {

  private ObjectMapper mapper;

  @Override
  public void close() {
  }

  @Override
  public void configure(final Map<String, ?> settings, final boolean isKey) {
    mapper = new ObjectMapper();
  }

  @Override
  public T deserialize(final String topic, final byte[] bytes) {
    try {
      return mapper.readValue(bytes, new TypeReference<T>() {
      });
    } catch (final IOException e) {
      throw new IllegalArgumentException(e);
    }
  }
}

序列化程序工作得很好，但是当涉及到在消费消息时反序列化值时，我得到了一个LinkedHashMap而不是所需的对象，请告诉我我错在哪里，提前感谢。

Answer 1

有些情况需要确认：

1. 您的串行器工作正常
2. Deserializer只是工作，但它返回了一个LinkedHashMap而不是您期望的对象，对吗？并且您无法将该LinkedHashMap转换为您的对象。

我发现问题转移到如何将LinkedHashMap转换/投射到对象，而您使用了ObjectMapper。如果所有情况都可以确认，我在这里找到了一个很好的帖子，可以回答您的问题将LinkedHashMap投射到复杂对象

mapper.convertValue(desiredObject, new TypeReference<type-of-desiredObject>() { })

ObjectMapper的API在[这里]（https://fasterxml.github.io/jackson-databind/javadoc/2.3.0/com/fasterxml/jackson/databind/ObjectMapper.html#convertValue（java.lang.Object，com.fasterxml.jackson.core.type.TypeReference））

我希望我没有错过你的意图，你可以补充必要的情况，所以有人或我可以改善这个答案。