KAFKA Custom Deserializer преобразует в Java Object ⇐ JAVA

[Anonymous]

Я использую Spring Kafka Integration, и у меня мое собственное значение Generic Serializer /Deserializer, как показано ниже < /p>


serializer: < /p>
< /blockquote>

Код: Выделить всё

public class KafkaSerializer implements Serializer {

private ObjectMapper mapper;

@Override
public void close() {
}

@Override
public void configure(final Map 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);
}
}
}



desisializer: < /p>
< /blockquote>

public class KafkaDeserializer implements Deserializer {

private ObjectMapper mapper;

@Override
public void close() {
}

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

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

Serializer работает отлично, но когда речь идет о десериализации значений при употреблении сообщения, я получаю LinkedHashmap вместо желаемого объекта, пожалуйста, просветите меня, где я ошибаюсь, заранее.

Подробнее здесь: https://stackoverflow.com/questions/435 ... ava-object