如何将sinkrecord转换为json字符串?

31moq8wy  于 2021-06-05  发布在  Kafka
关注(0)|答案(1)|浏览(463)

想象 myAPICreate 需要json字符串。

public void put(Collection<SinkRecord> collection) {
        for (SinkRecord record : collection) {
            JSONObject recordJson = toJSON(record.value());
            String recordJsonString = recordJson.toString();

            myAPICreate(recordJsonString);
        }
    }
``` `toJSON` 是我定义的一个助手,它只获取记录并返回一个jsonobject。

JSONObject json = new JSONObject()
.put("a", record.getString("a"))
.put("b", record.getString("b"))
.put("c", record.getString("c"));

我觉得我可能在这里做很多多余的工作。有必要输入代码吗 `put` 将它转换成json或者有没有一种方法可以使用转换器 `record` 已经以json或json字符串的形式出现了?那我就过去吧 `myAPICreate(record.value().toString())` 不需要手动操作?
7vux5j2d

7vux5j2d1#

当您创建 SinkRecord ,您有一个带有键和值对象的键和值架构。这些物体应该是 Struct 必须使用匹配的 Schema 在连接器配置中,您将使用 JSONConverter (或其他转换器)以获取序列化输出

相关问题