Flink CDC里请问下支持pgsql内核是TBase吗？

Flink CDC 支持 PostgreSQL，但不支持 TBase，以下是一个详细的说明：

Flink CDC 简介

Flink CDC（Change Data Capture）是 Apache Flink 的一个子项目，用于捕获数据库中的数据变更并将其转换为 Flink 流数据，Flink CDC 支持多种数据库，包括 MySQL、PostgreSQL、Oracle 等。

支持的数据库内核

Flink CDC 支持以下数据库内核：

数据库类型	是否支持
MySQL	是
PostgreSQL	是
Oracle	是
TBase	否

TBase 与 Flink CDC

TBase 是一款基于 PostgreSQL 内核的分布式数据库，虽然 Flink CDC 支持 PostgreSQL，但它并不直接支持 TBase，要在 TBase 上使用 Flink CDC，您需要在 Flink 应用程序中配置 TBase 的连接信息，并使用适用于 PostgreSQL 的 Flink CDC 连接器。

如何在 TBase 上使用 Flink CDC

以下是在 TBase 上使用 Flink CDC 的步骤：

1、配置 Flink 环境，确保已安装 Flink CDC 插件。

2、在 Flink 应用程序中配置 TBase 的连接信息，

Properties properties = new Properties();
properties.setProperty("bootstrap.servers", "tbasehostname:port");
properties.setProperty("group.id", "yourgroupid");
properties.setProperty("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
properties.setProperty("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

3、使用适用于 PostgreSQL 的 Flink CDC 连接器连接到 TBase：

DataStream<Row> stream = env.addSource(KafkaSource.<Row>builder()
    .setBootstrapServers("tbasehostname:port")
    .setTopics("yourtopic")
    .setGroupId("yourgroupid")
    .setValueDeserializer(new RowDeserializationSchema.Builder().build())
    .build());

4、根据需要对数据进行处理和转换。

请注意，虽然可以在 TBase 上使用 Flink CDC，但由于 TBase 是基于 PostgreSQL 内核的分布式数据库，因此可能会遇到一些与单机 PostgreSQL 不同的问题，在实际应用中，请根据具体情况进行调整。