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