维护 Openflow Connector for Kinesis¶

连接器创建的 DynamoDB 表¶

对于连接器中配置的每个 Kinesis 应用程序名称，KCL 会创建三个 DynamoDB 表：

<Kinesis Application Name>

存储流中每个分片的检查点序列号。这会跟踪已处理的记录。

<Kinesis Application Name>-CoordinatorState

当多个处理器共用相同的应用程序名称时，用于工作线程之间的协调。

<Kinesis Application Name>-WorkerMetricStats

供工作线程报告在工作分配期间使用的指标。

在这些表名称中，<Kinesis Application Name> 是设置连接器时提供的值。

如果多个处理器使用相同的应用程序名称，它们将协作使用流中的数据并共享这些表。如果处理器使用不同的应用程序名称，则每个处理器都会创建自己的一组表来独立跟踪已使用的记录。

有关 DynamoDB 表的更多信息，请参阅 AWS Kinesis 客户端库文档 (https://docs.aws.amazon.com/streams/latest/dev/kcl-dynamoDB.html)。

通过更改应用程序名称进行重置¶

重置连接器状态的最简单方法是更改 Kinesis 应用程序名称参数：

1. 停止连接器。

2. 导航到连接器的参数上下文。

3. 将 Kinesis Application Name 参数值更改为新值。

4. 启动连接器。

连接器将使用新的应用程序名称创建新的 DynamoDB 表，并从 Kinesis 初始流位置 参数指定的位置开始使用记录。

通过删除 DynamoDB 表进行重置¶

或者，您可以通过删除现有的 DynamoDB 表来重置连接器状态：

1. 停止连接器。

2. 在 AWS 控制台中或使用 AWS CLI，删除三个与应用程序名称关联的 DynamoDB 表：

   • <Kinesis Application Name>

   • <Kinesis Application Name>-CoordinatorState

   • <Kinesis Application Name>-WorkerMetricStats

3. 启动连接器。

连接器会重新创建这些表，并从 Kinesis 初始流位置 参数指定的位置开始使用记录。