org.apache.kafka.common.errors.SerializationException: Error deserializing key/value for partition

发布网友发布时间：2023-04-01 07:09

共1个回答

热心网友时间：2023-11-18 04:54

报错信息：

如果kafka consumer使用的JsonDeserializer，需要配置 trusted.packages，*是所有，也可以配置上你消息对象所在的具体的包。

如果使用的configuration方式配置的kafka consumer：

声明：本网页内容为用户发布，旨在传播知识，不代表本网认同其观点，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。E-MAIL:11247931@qq.com

org.apache.kafka.common.errors.SerializationException: Error deserializing key&#47;value for partition