요청에 헤더 필드를 추가 할 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);
}
이것은 작동합니다
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
이 기사는 인터넷에서 수집됩니다. 재 인쇄 할 때 출처를 알려주십시오.
침해가 발생한 경우 연락 주시기 바랍니다[email protected] 삭제
몇 마디 만하겠습니다