[feature] Map native Avro logical type that are generated by the an upstream CDC source

datastax / pulsar-sink

An Apache Pulsar® sink for transferring events/messages from Pulsar topics to Apache Cassandra®, DataStax Astra or DataStax Enterprise (DSE) tables.

Apache License 2.0

14 stars 10 forks source link

[feature] Map native Avro logical type that are generated by the an upstream CDC source #54

Closed aymkhalil closed 1 year ago

aymkhalil commented 1 year ago

This patch adds support for the native Avro logical type that are generated by the an upstream CDC source. Those are namely [date, time-micros, timstamp-millis] as can be found here

The new types will be gated behind the decodeCDCDataTypes that was introduced in this PR. All other CDC logical types are already supported.