diff --git a/docs/content/docs/connectors/datastream/kinesis.md b/docs/content/docs/connectors/datastream/kinesis.md index 0cbc47df..4de7d355 100644 --- a/docs/content/docs/connectors/datastream/kinesis.md +++ b/docs/content/docs/connectors/datastream/kinesis.md @@ -99,6 +99,7 @@ val kinesisEvents = env.fromSource(kdsSource, WatermarkStrategy.forMonotonousTim .uid("custom-uid") ``` {{< /tab >}} +{{< /tabs >}} The above is a simple example of using the `KinesisStreamsSource`. - The Kinesis stream being read from is specified using the Kinesis Stream ARN.