Flink CDC里我现在想postgresql 能实时入库 hive，并且能实现断点续传，怎么办？

对于将PostgreSQL数据实时入库Hive并实现断点续传的需求，以下是一些建议：

1. 使用Flink CDC：Flink CDC是一个用于捕获数据库变更的库，它支持多种数据库源，包括PostgreSQL。您可以使用Flink CDC来实时捕获PostgreSQL的数据变更，并将其发送到Kafka等消息队列中。

2. 使用Debezium：Debezium是一个开源的分布式数据变更捕获平台，它可以与PostgreSQL进行集成。您可以使用Debezium来捕获PostgreSQL的数据变更，并将其发送到Kafka等消息队列中。

3. 使用Apache Kafka：Kafka是一个分布式流处理平台，可以作为数据管道的核心组件。您可以使用Kafka来接收来自Flink CDC或Debezium的数据变更，并进行缓冲和分发。

4. 使用Apache Flink：Flink是一个分布式流处理框架，可以对Kafka中的数据进行处理和转换。您可以使用Flink来消费Kafka中的数据变更，并将其写入Hive中。

5. 实现断点续传：为了实现断点续传，您可以考虑以下方法：

   • 在Flink中启用checkpoint机制，以便在任务失败时可以从上次的checkpoint恢复。
   • 在Kafka中设置合适的offset管理策略，以确保数据不会丢失或重复处理。
   • 在Hive中使用分区表，并根据时间或其他标识符进行分区，以便在任务失败后可以从上次的分区开始重新处理。

支持的，用savepoint打个快照，再从快照启动。此回答来自钉群Flink CDC 社区。