Skip to content

Commit

Permalink
[hotfix][Connectors/Kinesis] Fixed typo in the Kinesis connector docu…
Browse files Browse the repository at this point in the history
…mentation
  • Loading branch information
MRKKmrkk committed Aug 3, 2023
1 parent 29c4828 commit d0e43cf
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion docs/content.zh/docs/connectors/datastream/kinesis.md
Original file line number Diff line number Diff line change
Expand Up @@ -128,7 +128,7 @@ kinesis = env.add_source(FlinkKinesisConsumer("stream-1", SimpleStringSchema(),
{{< /tab >}}
{{< /tabs >}}

上面是一个使用消费者的简单例子。 消费者使用 `java.util.Properties` 实例配置,配置的健可以在 `AWSConfigConstants` (AWS 特定的参数)
上面是一个使用消费者的简单例子。 消费者使用 `java.util.Properties` 实例配置,配置的键可以在 `AWSConfigConstants` (AWS 特定的参数)
`ConsumerConfigConstants` (Kinesis 消费者参数)。这个例子演示了在 AWS区域 "us-east-1" 消费一个 Kinesis流。AWS 证书使用基本的方法提供:AWS访问密钥
ID和秘密访问密钥直接在配置中提供。数据从 Kinesis流中最新的位置消费(另一个选项是把 `ConsumerConfigConstants.STREAM_INITIAL_POSITION`
设置为 `TRIM_HORIZON` ,让消费者从 Kinesis 流中可能的最早记录开始读取)。
Expand Down

0 comments on commit d0e43cf

Please sign in to comment.