Skip to content

Commit

Permalink
Organize all the time data types.
Browse files Browse the repository at this point in the history
  • Loading branch information
Tang8330 committed Jul 25, 2024
1 parent 58e332d commit 3e59141
Showing 1 changed file with 7 additions and 5 deletions.
12 changes: 7 additions & 5 deletions lib/debezium/types.go
Original file line number Diff line number Diff line change
Expand Up @@ -37,17 +37,19 @@ const (
MicroTimestamp SupportedDebeziumType = "io.debezium.time.MicroTimestamp"
NanoTimestamp SupportedDebeziumType = "io.debezium.time.NanoTimestamp"
Date SupportedDebeziumType = "io.debezium.time.Date"
Time SupportedDebeziumType = "io.debezium.time.Time"
MicroTime SupportedDebeziumType = "io.debezium.time.MicroTime"
NanoTime SupportedDebeziumType = "io.debezium.time.NanoTime"
Year SupportedDebeziumType = "io.debezium.time.Year"
TimeWithTimezone SupportedDebeziumType = "io.debezium.time.ZonedTime"
DateTimeWithTimezone SupportedDebeziumType = "io.debezium.time.ZonedTimestamp"
MicroDuration SupportedDebeziumType = "io.debezium.time.MicroDuration"
DateKafkaConnect SupportedDebeziumType = "org.apache.kafka.connect.data.Date"
TimeKafkaConnect SupportedDebeziumType = "org.apache.kafka.connect.data.Time"
DateTimeKafkaConnect SupportedDebeziumType = "org.apache.kafka.connect.data.Timestamp"

// All the possible time data types
Time SupportedDebeziumType = "io.debezium.time.Time"
MicroTime SupportedDebeziumType = "io.debezium.time.MicroTime"
NanoTime SupportedDebeziumType = "io.debezium.time.NanoTime"
TimeWithTimezone SupportedDebeziumType = "io.debezium.time.ZonedTime"
TimeKafkaConnect SupportedDebeziumType = "org.apache.kafka.connect.data.Time"

KafkaDecimalType SupportedDebeziumType = "org.apache.kafka.connect.data.Decimal"
KafkaVariableNumericType SupportedDebeziumType = "io.debezium.data.VariableScaleDecimal"

Expand Down

0 comments on commit 3e59141

Please sign in to comment.