Flink CDC 中java: PostgresSource中是 private 访问控制？

在 Flink CDC 中，PostgresSource 类确实存在一些私有（private）访问控制的成员变量和方法。这是为了封装和保护类的内部实现细节，以确保类的正确性和稳定性。

以下是 PostgresSource 类中的一些私有成员变量和方法：

- private final PostgresSourceOptions options;：用于存储 PostgresSource 的配置选项，包括数据库连接信息、表信息、事件时间等。 - private volatile boolean running;：用于标识 PostgresSource 是否正在运行。 - private final AtomicReference<Throwable> error;：用于存储 PostgresSource 运行过程中可能出现的异常信息。 - private final PostgresConnectionProvider connectionProvider;：提供 PostgreSQL 数据库连接的实例。 - private final PostgresSequenceNumGenerator sequenceNumGenerator;：用于生成变更数据的序列号。 - private final PostgresSnapshotSplitReader splitReader;：用于读取 PostgreSQL 数据库中的快照数据。 - private final PostgresContinuousSplitReader continuousSplitReader;：用于读取 PostgreSQL 数据库中的增量变更数据。

此外，还有一些私有方法用于验证选项、启动连续读取器等。

根据您提供的截图，可能出现该类不可见的原因可能是导入的包或依赖项不正确，或者确实需要某些权限来访问该类。请确保在代码中正确导入了 PostgresSource 类所在的包，并检查您是否具有访问该类的权限。

在 Flink CDC 中，PostgresSource 是一个 Java 类，用于实现从 PostgreSQL 数据库中读取变更数据的功能。在 PostgresSource 类中，确实存在一些 private 访问控制的成员变量和方法，这是为了封装和保护类的内部实现细节，以确保类的正确性和稳定性。
具体来说，在 PostgresSource 类中，存在以下 private 成员变量和方法：
private final PostgresSourceOptions options;
该成员变量用于存储 PostgresSource 的配置选项，包括数据库连接信息、表信息、事件时间等。
private volatile boolean running;
该成员变量用于标识 PostgresSource 是否正在运行。
private final AtomicReference error;
该成员变量用于存储 PostgresSource 运行过程中可能出现的异常信息。
private final PostgresConnectionProvider connectionProvider;
该成员变量用于提供 PostgreSQL 数据库连接。
private final PostgresSequenceNumGenerator sequenceNumGenerator;
该成员变量用于生成变更数据的序列号。
private final PostgresSnapshotSplitReader splitReader;
该成员变量用于读取 PostgreSQL 数据库中的快照数据。
private final PostgresContinuousSplitReader continuousSplitReader;
该成员变量用于读取 PostgreSQL 数据库中的增量变更数据。
private void validateOptions(PostgresSourceOptions options);
该方法用于验证 PostgresSource 的配置选项是否正确。
private void startContinuousReader() throws Exception;
该方法用于启动连续读取 PostgreSQL 数据库中的增量变更数据。
private void stopContinuo

你是不是导错了包，看下pom和 import，代码最上面的import，看起来是有问题的，此回答整理自钉群“Flink CDC 社区”