InsertField 변환은 삭제 표시 메시지에 적용되지 않습니다.
postgres 10.1 / debezium 1.2.1 버전 / kafka 2.4.1 버전을 사용하고 있습니다.
예를 들면.
{
...
"transforms": "InsertField",
"transforms.InsertField.type": "org.apache.kafka.connect.transforms.InsertField$Key",
"transforms.InsertField.static.field": "__host",
"transforms.InsertField.static.value": "abc.com",
...
}
key - {"id":1, "__host": "abc.com"}, value - {"id":1, "__host": "abc.com", "col1": 1, "col2": "a"}
InsertField변환을 적용하지 않음 )key - {"id":1, "__host": "abc.com"} value - {"id":1, "__host": "abc.com", "col1": null, "col2": null}
key - {"id":1} value - null
왜 그런가요? 버그인가요? 아니면 내가 틀렸나 요?
InsertField삭제 표시 메시지에 대한 예상 변환 동작 :
키 필드가 삽입되고 값은 null로 유지됩니다.
그러나 Kafka Connect 버전 (2.4.1)에는 버그가 있습니다. 키 필드가 삽입되지 않았습니다. KAFKA-9707 에서 수정되었습니다 : InsertField. 키 변환이 삭제 표시 레코드에 적용되어야합니다.
Kafka Connect 클러스터를 일부 수정 버전 (예 : 2.4.2)으로 업그레이드 할 수 있습니다.
이 기사는 인터넷에서 수집됩니다. 재 인쇄 할 때 출처를 알려주십시오.
침해가 발생한 경우 연락 주시기 바랍니다[email protected] 삭제
몇 마디 만하겠습니다