我们正在使用kinesis flink connector
从 flink 消费和生成记录到 kinesis 中。由于它正在使用KCL
,它应该使用dynamoDB
它消耗的运动流的偏移量进行条目。我们无法在 中看到任何具有应用程序名称的表dynamoDB
。这是预期的行为吗?Flink 连接器版本:1.8 Flink 版本:1.8.0
问问题
129 次
我们正在使用kinesis flink connector
从 flink 消费和生成记录到 kinesis 中。由于它正在使用KCL
,它应该使用dynamoDB
它消耗的运动流的偏移量进行条目。我们无法在 中看到任何具有应用程序名称的表dynamoDB
。这是预期的行为吗?Flink 连接器版本:1.8 Flink 版本:1.8.0