如何通过JDBC连接器将oracle中的日期类型列转换为kafka主题上的int类型

Question

我正在尝试使用 JDBC 连接器将数据从一个或 oracle 表提取到 kafka 主题。在我的源表中，有一个字段 - test_date 是“日期”数据类型。此列中的示例值类似于 -11/20/1997 12:00:00 AM。

我得到的该字段主题的模式是类型：long -

“名称”：“TEST_DATE”， “类型”： [ “无效的”， { “类型”：“长”， “连接版本”：1， "connect.name": "org.apache.kafka.connect.data.Timestamp", “逻辑类型”：“时间戳毫秒” }

但是我想用 int 类型得到它，如下所示：

"type": [
    "null",
    {
      "type": "int",
      "connect.version": 1,
      "connect.name": "org.apache.kafka.connect.data.Date",
      "logicalType": "date"

我的值转换设置就像 - “value.converter”：“io.confluence.connect.avro.AvroConverter”

有什么帮助吗，如何实现这一目标？

我尝试了一些东西，但它不起作用。另一件事是我只想以这种方式处理一个字段，不想更改其他日期字段上的任何内容。

Answer 1

想要以 int 类型得到这个

以毫秒为单位的 Unix 纪元时间应该总是很长

如果您想类型转换为其他任何内容（例如返回字符串），请查看使用

TimestampConverter

类