维护 Openflow Connector for Amazon Kinesis Data Streams¶

连接器创建的 DynamoDB 表¶

连接器会使用 AWS Kinesis Application Name 中所指定的名称来创建 DynamoDB 表。该表用于存储流中每个分片已设置检查点的序列号，以此追踪哪些记录已经被处理过。

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

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

重置连接器状态的最简单方法是更改 AWS Kinesis Application Name 参数：

1. 停止连接器。

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

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

4. 启动连接器。

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

通过删除 DynamoDB 表进行重置¶

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

1. 停止连接器。

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

3. 启动连接器。

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