org.apache.kafka.common.errors.serializationexception with org.w3c.dom.element字段

sq1bmfud  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(221)

我尝试向Kafka发送消息,并在另一个服务中获取此消息。我补充说

org.springframework.kafka.support.serializer.JsonDeserializer //consumer side
org.springframework.kafka.support.serializer.JsonSerializer //produser side

我尝试用字段发送对象:

org.w3c.dom.Element;

@XmlAnyElement
protected Element any;

消息发送成功,但在用户端我收到错误:

Caused by: org.apache.kafka.common.errors.SerializationException: Can't deserialize data [[123, 34, 114, 101...

Caused by: com.fasterxml.jackson.databind.JsonMappingException: Problem deserializing property 'any' (expected type: [simple type, class org.w3c.dom.Element]; actual type: `com.sun.org.apache.xerces.internal.dom.DeferredDocumentImpl`), problem: java.lang.ClassCastException@4db05b26

我通过以下命令在topik中显示此mesage:

./kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic my-topic  --from-beginning

这个信息看起来很正确:

"to": "eyJzaWQi...",
 "messagePrimaryContent": {
    "any": "<?xml version=\"1.0\" encoding=\"UTF-16\"?>\n<ImportCh...(another xml text)"
 },
 "personalSignature": null,

如何反序列化此邮件?
如果我把这个东西 org.w3c.dom.Element 一切正常。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题