我们使用java配置producer来实现异步重试机制
在用户端，我们使用消息驱动适配器（xml配置）。
在制作人那一方确认一下

props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,MessageSerializer.class.getName());

在producer上，我们没有设置编码器实现的选项，因为它只支持序列化程序接口实现
messageserializer实现序列化程序
在消费者方面，我们没有反序列化选项，因为它只支持解码器接口实现：

<int-kafka:message-driven-channel-adapter

               id="inAdapter"
               channel="fromKafka"
               connection-factory="connectionFactory"
               key-decoder="kafkaKeyDecoder"
               payload-decoder="kafkaDecoder"                              
               topics="${topic.list}"
               offset-manager="offsetManager"/>

Kafka编码器实现解码器
在序列化过程中出现错误之前，请您建议如何处理。