想象 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())` 不需要手动操作?
1条答案
按热度按时间7vux5j2d1#
当您创建
SinkRecord
,您有一个带有键和值对象的键和值架构。这些物体应该是Struct
必须使用匹配的Schema
在连接器配置中,您将使用JSONConverter
(或其他转换器)以获取序列化输出