kafka connect smt添加kafka头字段

4ioopgfo  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(488)

我需要找到或写一个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);

}
zdwk9cvp

zdwk9cvp1#

这应该管用

Headers headers = new ConnectHeaders();
headers.add(myKey, myValue, mySchema);
headers.forEach(h -> record.headers().add(h));

connectheaders信息可在此处找到-https://kafka.apache.org/25/javadoc/org/apache/kafka/connect/header/headers.html

相关问题