我需要找到或写一个smt,将添加头字段的请求。请求缺少一些类型字段,我想添加它们。
如何在smt中添加一个标题?我所看到的只是下面这样的记录转换,但是如果它是我想要更改或添加字段的标题呢?
private R applySchemaless(R record) {
final Map<String, Object> value = requireMap(operatingValue(record), PURPOSE);
// record.headers.add(Header) but how do I define the header
// or record.headers.add(String, Schema) but I am not sure how to define Schema?
final Map<String, Object> updatedValue = new HashMap<>(value);
updatedValue.put(fieldName, getRandomUuid());
return newRecord(record, null, updatedValue);
}
1条答案
按热度按时间zdwk9cvp1#
这应该管用
connectheaders信息可在此处找到-https://kafka.apache.org/25/javadoc/org/apache/kafka/connect/header/headers.html