想象一下，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())而不必手动进行？
当你创建一个SinkRecord，你有钥匙和值模式W / A键和值的对象。这些对象应该是必须使用匹配项创建的Struct实例Schema
在连接器配置中，然后您将使用JSONConverter（或其他转换器）获取序列化的输出
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句