卡夫卡序列化反序列化问题答案

【问题标题】：Kafka serialize-deserialize issue卡夫卡序列化反序列化问题
【发布时间】：2017-06-19 11:11:46
【问题描述】：

我们使用java配置producer实现异步重试机制

在消费者端，我们使用消息驱动的适配器（xml 配置）。

确定在生产者方面我们有

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

在producer上，我们没有设置encoder实现的选项，因为它只支持序列化接口实现

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"/>

kafkaDecoder 实现解码器

在序列化过程中出现错误，请您建议如何处理。

【问题讨论】：

标签： java spring apache-kafka spring-integration

【解决方案1】：

您使用的是旧版本的 spring-integration-kafka；它不再那样配置了；当前版本是 2.1.0，它位于 spring-kafka 1.1.2 之上。

集成组件记录在spring-kafka reference 中。配置 Spring Kafka 本身在这本书的其他地方。

【讨论】：