: Error deserializing Avro message for id -1\nCaused by: org.apache.kafka.common.errors.SerializationException": "sink"编辑2Outputting 1000000 to test_hdfs
Exception in thread "main" org.apache.kafka.common.errors.SerializationExceptio
我将其中一个字段从string更改为LocalDate类型,现在我的Kafka Consumer无法处理它。在读取下面的错误之后,看起来我需要反序列化这个值。我需要创建一个自定义的反序列化程序吗?或者我可以修改我的consumerFactory中的一些配置吗?Caused by: org.apache.kafka.common.errors.SerializationException: Can't deserialize data [[...125]] from
我已经永久删除了kafka主题的模式,现在我无法从主题中反序列化消息,该怎么办。堆栈跟踪:A 500 error has occurred: Request processing failed; nested exception is org.apache.kafka.common.errors.SerializationException: Error retrieving Avro schema for id 100869org.apache.kafka.c