apache-nifi - 如何在nifi中解析mysql json列

Question

我使用CaptureChangeMySQL++从mysql（5.7 ConvertJSONToSQL）PutSQL同步数据，在我的表中有一个json类型列，我想将json转换为sql文字，new String((bytep[]) json, StandardCharset.UTF_8)用来解析它但得到错误的结果：

字节 [] 是：

表中的实际值为： [{id: 13182, name: "2730"}]

那么如何正确解析 mysql json 值呢？

标签： apache-nifi

Answer 1

用来JsonBinary.parseAsString(byte[])解析。