Skip to main content

Transformations

oracdc provides several Single Message Transformations (SMTs) for converting between Oracle-native data types and standard Kafka Connect types.

OraNumberConverter​

Class: solutions.a2.kafka.transforms.OraNumberConverter

Converts native Oracle NUMBER bytes (solutions.a2.cdc.oracle.data.OraNumber / oracle.sql.NUMBER) to standard Kafka Connect numeric types.

Use this transformation when consuming oracdc data with a2.oracdc.schemas=true and you need standard numeric types for downstream consumers.

OraIntervalConverter​

Class: solutions.a2.kafka.transforms.OraIntervalConverter

Converts native Oracle INTERVAL bytes to standard Kafka Connect types:

  • solutions.a2.cdc.oracle.data.OraIntervalYM (INTERVAL YEAR TO MONTH)
  • solutions.a2.cdc.oracle.data.OraIntervalDS (INTERVAL DAY TO SECOND)

HeaderToFieldConverter​

Class: solutions.a2.kafka.transforms.HeaderToFieldConverter

Converts Kafka record headers to fields within the record value. Useful when header information needs to be included in the record for downstream processing.

KeyToValueConverter​

Class: solutions.a2.kafka.transforms.KeyToValueConverter

Converts fields from the record key schema into the value schema. Useful when key fields need to be duplicated in the value for systems that don't process key schemas.

ToLowerCaseNameConverter​

Class: solutions.a2.kafka.transforms.ToLowerCaseNameConverter

Converts schema names and field names to lowercase. Useful when the target system requires lowercase identifiers (e.g., PostgreSQL).