Кафка сериализовать-Deserialize вопрос

Question

Мы используем конфигурацию Java для производителя для достижения асинхронного механизма Retry

и на стороне потребителя, мы используем сообщение приводимого адаптер (конфигурации XML).

определить, что на стороне производителя есть

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

на производителя, мы не имеем вариант для установки датчика реализации, как это только поддерживает реализацию сериализатору интерфейса

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 реализует Decoder

Therfore получает ошибку во время сериализации, пожалуйста, вы можете предложить о том, как справитесь с этим.

Answer 1

Вы используете старую версию spring-integration-kafka; он больше не настроен таким образом; текущая версия 2.1.0, и она сидит поверх весны-кафки 1.1.2.

Компоненты интеграции задокументированы в spring-kafka reference. Настройка Spring Kafka сама по себе находится в другом месте этой книги.