Spring数据流JDBC Sink 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跟踪。随意分享您的想法/问题作为评论。

我们会尽快审核并解决。在此期间，请尝试通过将上游内容类型设置为text/plain来解决此问题。