Spring Data Flow JDBC Раковина JSON

Question

Я создал специальную раковину от JDBC Sink Starter. Входными данными в приемник является содержимое JSON, но когда приемник получает сообщение, в журналах появляется следующая ошибка:

 Property or field 'field' cannot be found on object of type 'byte[]'

Я использую свойство jdbc.columns следующим образом:

jdbc.columns=FIELD_COLUMN:field

Процессор, питающий приемник, отправляет сообщение как:

String payload = objectMapper.writeValueAsString(message);
                output.send(MessageBuilder
                        .withPayload(payload)
                        .setHeader("contentType", "application/json")
                        .build());

Answer 1

Для улучшения работы с различными типами полезных данных требуется улучшение, начиная с версии 2.0.x jdbc app-starters.

Мы отслеживаем это через spring-cloud-stream-app-starters / jdbc # 48 . Не стесняйтесь делиться своими мыслями / вопросами в качестве комментариев.

Мы скоро рассмотрим и решим проблему. А пока, пожалуйста, попробуйте обходной путь, установив восходящий тип контента на данный момент как text/plain.