Spring 数据流 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

从 jdbc app-starters 的 2.0.x 版本开始，需要进行改进才能显式处理不同类型的负载。

我们正在通过 spring-cloud-stream-app-starters/jdbc#48 进行跟踪。欢迎在评论中分享您的 thoughts/questions。

我们会尽快审核并解决。同时，请暂时将上游内容类型设置为 text/plain 来尝试解决方法。

Spring 数据流 JDBC 接收器 JSON

Spring Data Flow JDBC Sink JSON

spring-integration

spring-cloud-dataflow