Transformaty docelowe
W repo JSON_TRANSFORMS na branchu feature/combined_transform są transformaty do użycia na targetowym connectorze:
DropSchemaDefaults - jeśli w schema w kafce pole ma default value modyfikuje schema, żeby usunąć. Używane, żeby JDBCSink nie wstawiał default value, gdy pole ma wartość null
RemoveNotModifiedFields - usuwa z wiadomości pola, które się nie zmieniły (mają taką samą wartość, lub oba są null)
TargetUnwrapChangedFields - łączy transformatę unwrap dla debezium z dwoma powyższymi transformatami w jedną
Transformaty były testowane, ale przed wdrożeniem do produkcyjnego rozwiązania, trzeba je dokładniej przetestować w skrajnych przypadkach i różnych typach eventów.
DropSchemaDefaults i TargetUnwrapChangedFields używa w środku cachowania, które było skopiowane z repo Debezium (tam też trzeba sprawdzić szczegóły transformaty unwrap)
Last updated