Kafka JDBC 连接器 - 在 CLOB 字段中提取 JSON 并将其持久化到 Kafka 主题

Question

我有格式良好的 JSON 数据，该数据保存在 Oracle 11g 表的 CLOB 字段中。

CREATE TABLE INTERFACE_KAFKA_QUEUE
(
  AUDIT_NUMBER         NUMBER,
  MESSAGE              CLOB,
  DATE_INSERTED        DATE DEFAULT SYSDATE
)

我想使用 Kafka JDBC 连接器从表中提取此 JSON 数据并将其发送到 Kafka 主题。

我遇到的问题是，当 JSON 最终出现在主题上时，它是一个字符串，而不是一个 JSON 对象。

有谁知道是否可以设置连接器并将 JSON 作为主题上的有效负载，如果可以，连接器设置是什么？

我不想去创建很多额外的移动部件或使用 KSQL 来实现这一点。

Answer 1

JSON 是一个字符串。它是一种表示法，而不是序列化格式； UTF-8 是序列化格式。