chore(kinesis): make examples compile (#17548)

Fix examples and turn on strict mode for `kinesis` and related modules.

----

*By submitting this pull request, I confirm that my contribution is made under the terms of the Apache-2.0 license*

packages/@aws-cdk/aws-kinesis/README.md

@@ -34,8 +34,8 @@ Using the CDK, a new Kinesis stream can be created as part of the stack using th
 your own identifier to the stream. If not, CloudFormation will generate a name.
 
 ```ts
-new Stream(this, "MyFirstStream", {
- streamName: "my-awesome-stream"
+new kinesis.Stream(this, 'MyFirstStream', {
+ streamName: 'my-awesome-stream',
 });
 ```
 
@@ -44,10 +44,10 @@ to specify how long the data in the shards should remain accessible.
 Read more at [Creating and Managing Streams](https://docs.aws.amazon.com/streams/latest/dev/working-with-streams.html)
 
 ```ts
-new Stream(this, "MyFirstStream", {
- streamName: "my-awesome-stream",
+new kinesis.Stream(this, 'MyFirstStream', {
+ streamName: 'my-awesome-stream',
  shardCount: 3,
- retentionPeriod: Duration.hours(48)
+ retentionPeriod: Duration.hours(48),
 });
 ```
 
@@ -59,28 +59,26 @@ server-side encryption using an AWS KMS key for a specified stream.
 Encryption is enabled by default on your stream with the master key owned by Kinesis Data Streams in regions where it is supported.
 
 ```ts
-new Stream(this, 'MyEncryptedStream');
+new kinesis.Stream(this, 'MyEncryptedStream');
 ```
 
 You can enable encryption on your stream with a user-managed key by specifying the `encryption` property.
 A KMS key will be created for you and associated with the stream.
 
 ```ts
-new Stream(this, "MyEncryptedStream", {
- encryption: StreamEncryption.KMS
+new kinesis.Stream(this, 'MyEncryptedStream', {
+ encryption: kinesis.StreamEncryption.KMS,
 });
 ```
 
 You can also supply your own external KMS key to use for stream encryption by specifying the `encryptionKey` property.
 
 ```ts
-import * as kms from "@aws-cdk/aws-kms";
+const key = new kms.Key(this, 'MyKey');
 
-const key = new kms.Key(this, "MyKey");
-
-new Stream(this, "MyEncryptedStream", {
- encryption: StreamEncryption.KMS,
- encryptionKey: key
+new kinesis.Stream(this, 'MyEncryptedStream', {
+ encryption: kinesis.StreamEncryption.KMS,
+ encryptionKey: key,
 });
 ```
 
@@ -91,32 +89,20 @@ Any Kinesis stream that has been created outside the stack can be imported into
 Streams can be imported by their ARN via the `Stream.fromStreamArn()` API
 
 ```ts
-const stack = new Stack(app, "MyStack");
-
-const importedStream = Stream.fromStreamArn(
- stack,
- "ImportedStream",
- "arn:aws:kinesis:us-east-2:123456789012:stream/f3j09j2230j"
+const importedStream = kinesis.Stream.fromStreamArn(this, 'ImportedStream',
+ 'arn:aws:kinesis:us-east-2:123456789012:stream/f3j09j2230j',
 );
 ```
 
 Encrypted Streams can also be imported by their attributes via the `Stream.fromStreamAttributes()` API
 
 ```ts
-import { Key } from "@aws-cdk/aws-kms";
-
-const stack = new Stack(app, "MyStack");
-
-const importedStream = Stream.fromStreamAttributes(
- stack,
- "ImportedEncryptedStream",
- {
- streamArn: "arn:aws:kinesis:us-east-2:123456789012:stream/f3j09j2230j",
- encryptionKey: kms.Key.fromKeyArn(
- "arn:aws:kms:us-east-1:123456789012:key/12345678-1234-1234-1234-123456789012"
- )
- }
-);
+const importedStream = kinesis.Stream.fromStreamAttributes(this, 'ImportedEncryptedStream', {
+ streamArn: 'arn:aws:kinesis:us-east-2:123456789012:stream/f3j09j2230j',
+ encryptionKey: kms.Key.fromKeyArn(this, 'key',
+ 'arn:aws:kms:us-east-1:123456789012:key/12345678-1234-1234-1234-123456789012',
+ ),
+});
 ```
 
 ### Permission Grants
@@ -138,10 +124,10 @@ If the stream has an encryption key, read permissions will also be granted to th
 const lambdaRole = new iam.Role(this, 'Role', {
  assumedBy: new iam.ServicePrincipal('lambda.amazonaws.com'),
  description: 'Example role...',
-}
+});
 
-const stream = new Stream(this, 'MyEncryptedStream', {
-  encryption: StreamEncryption.KMS
+const stream = new kinesis.Stream(this, 'MyEncryptedStream', {
+ encryption: kinesis.StreamEncryption.KMS,
 });
 
 // give lambda permissions to read stream
@@ -165,10 +151,10 @@ If the stream has an encryption key, write permissions will also be granted to t
 const lambdaRole = new iam.Role(this, 'Role', {
  assumedBy: new iam.ServicePrincipal('lambda.amazonaws.com'),
  description: 'Example role...',
-}
+});
 
-const stream = new Stream(this, 'MyEncryptedStream', {
-  encryption: StreamEncryption.KMS
+const stream = new kinesis.Stream(this, 'MyEncryptedStream', {
+ encryption: kinesis.StreamEncryption.KMS,
 });
 
 // give lambda permissions to write to stream
@@ -186,9 +172,9 @@ The following write permissions are provided to a service principal by the `gran
 You can add any set of permissions to a stream by calling the `grant()` API.
 
 ```ts
-const user = new iam.User(stack, 'MyUser');
+const user = new iam.User(this, 'MyUser');
 
-const stream = new Stream(stack, 'MyStream');
+const stream = new kinesis.Stream(this, 'MyStream');
 
 // give my user permissions to list shards
 stream.grant(user, 'kinesis:ListShards');
@@ -199,7 +185,7 @@ stream.grant(user, 'kinesis:ListShards');
 You can use common metrics from your stream to create alarms and/or dashboards. The `stream.metric('MetricName')` method creates a metric with the stream namespace and dimension. You can also use pre-define methods like `stream.metricGetRecordsSuccess()`. To find out more about Kinesis metrics check [Monitoring the Amazon Kinesis Data Streams Service with Amazon CloudWatch](https://docs.aws.amazon.com/streams/latest/dev/monitoring-with-cloudwatch.html).
 
 ```ts
-const stream = new Stream(stack, 'MyStream');
+const stream = new kinesis.Stream(this, 'MyStream');
 
 // Using base metric method passing the metric name
 stream.metric('GetRecords.Success');
@@ -210,4 +196,3 @@ stream.metricGetRecordsSuccess();
 // using pre-defined and overriding the statistic
 stream.metricGetRecordsSuccess({ statistic: 'Maximum' });
 ```
-

packages/@aws-cdk/aws-kinesis/package.json

@@ -28,7 +28,14 @@
  ]
  }
  },
- "projectReferences": true
+ "projectReferences": true,
+ "metadata": {
+ "jsii": {
+ "rosetta": {
+ "strict": true
+ }
+ }
+ }
  },
  "repository": {
  "type": "git",

packages/@aws-cdk/aws-kinesis/rosetta/default.ts-fixture

@@ -0,0 +1,14 @@
+// Fixture with packages imported, but nothing else
+import { Construct } from 'constructs';
+import { Duration, Stack } from '@aws-cdk/core'; 
+import * as kinesis from '@aws-cdk/aws-kinesis';
+import * as kms from '@aws-cdk/aws-kms';
+import * as iam from '@aws-cdk/aws-iam';
+
+class Fixture extends Stack { 
+ constructor(scope: Construct, id: string) {
+ super(scope, id);
+
+ /// here
+ }
+}

packages/@aws-cdk/aws-kinesisanalytics-flink/README.md

@@ -37,16 +37,17 @@ aws-kinesisanalytics-runtime library to [retrieve these
 properties](https://docs.aws.amazon.com/kinesisanalytics/latest/java/how-properties.html#how-properties-access).
 
 ```ts
-import * as flink from '@aws-cdk/aws-kinesisanalytics-flink';
-
+declare const bucket: s3.Bucket;
 const flinkApp = new flink.Application(this, 'Application', {
- // ...
  propertyGroups: {
  FlinkApplicationProperties: {
  inputStreamName: 'my-input-kinesis-stream',
  outputStreamName: 'my-output-kinesis-stream',
  },
  },
+ // ...
+ runtime: flink.Runtime.FLINK_1_13,
+ code: flink.ApplicationCode.fromBucket(bucket, 'my-app.jar'),
 });
 ```
 
@@ -55,14 +56,13 @@ when the Flink job starts. These include parameters for checkpointing,
 snapshotting, monitoring, and parallelism.
 
 ```ts
-import * as logs from '@aws-cdk/aws-logs';
-
+declare const bucket: s3.Bucket;
 const flinkApp = new flink.Application(this, 'Application', {
  code: flink.ApplicationCode.fromBucket(bucket, 'my-app.jar'),
- runtime: file.Runtime.FLINK_1_13,
+ runtime: flink.Runtime.FLINK_1_13,
  checkpointingEnabled: true, // default is true
- checkpointInterval: cdk.Duration.seconds(30), // default is 1 minute
- minPauseBetweenCheckpoints: cdk.Duration.seconds(10), // default is 5 seconds
+ checkpointInterval: Duration.seconds(30), // default is 1 minute
+ minPauseBetweenCheckpoints: Duration.seconds(10), // default is 5 seconds
  logLevel: flink.LogLevel.ERROR, // default is INFO
  metricsLevel: flink.MetricsLevel.PARALLELISM, // default is APPLICATION
  autoScalingEnabled: false, // default is true

packages/@aws-cdk/aws-kinesisanalytics-flink/package.json

@@ -28,7 +28,14 @@
  ]
  }
  },
- "projectReferences": true
+ "projectReferences": true,
+ "metadata": {
+ "jsii": {
+ "rosetta": {
+ "strict": true
+ }
+ }
+ }
  },
  "repository": {
  "type": "git",

packages/@aws-cdk/aws-kinesisanalytics-flink/rosetta/default.ts-fixture

@@ -0,0 +1,14 @@
+// Fixture with packages imported, but nothing else
+import { Construct } from 'constructs';
+import { Duration, Stack } from '@aws-cdk/core'; 
+import * as flink from '@aws-cdk/aws-kinesisanalytics-flink';
+import * as logs from '@aws-cdk/aws-logs';
+import * as s3 from '@aws-cdk/aws-s3';
+
+class Fixture extends Stack { 
+ constructor(scope: Construct, id: string) {
+ super(scope, id);
+
+ /// here
+ }
+}

packages/@aws-cdk/aws-kinesisanalytics/package.json

@@ -28,7 +28,14 @@
  ]
  }
  },
- "projectReferences": true
+ "projectReferences": true,
+ "metadata": {
+ "jsii": {
+ "rosetta": {
+ "strict": true
+ }
+ }
+ }
  },
  "repository": {
  "type": "git",

packages/@aws-cdk/aws-kinesisfirehose-destinations/README.md

@@ -20,3 +20,7 @@ delivery stream. Destinations can be added by specifying the `destinations` prop
 defining a delivery stream.
 
 See [Amazon Kinesis Data Firehose module README](https://docs.aws.amazon.com/cdk/api/latest/docs/aws-kinesisfirehose-readme.html) for usage examples.
+
+```ts nofixture
+import * as destinations from '@aws-cdk/aws-kinesisfirehose-destinations';
+```

packages/@aws-cdk/aws-kinesisfirehose-destinations/package.json

@@ -32,7 +32,7 @@
  "metadata": {
  "jsii": {
  "rosetta": {
- "strict": false
+ "strict": true 
  }
  }
  }

packages/@aws-cdk/aws-kinesisfirehose-destinations/rosetta/default.ts-fixture

@@ -1,8 +1,9 @@
 // Fixture with packages imported, but nothing else
-import { Construct } from '@aws-cdk/core';
-import { S3Bucket } from '@aws-cdk/aws-kinesisfirehose-destinations';
+import { Construct } from 'constructs';
+import { Stack } from '@aws-cdk/core';
+import * as destinations from '@aws-cdk/aws-kinesisfirehose-destinations';
 
-class Fixture extends Construct {
+class Fixture extends Stack {
  constructor(scope: Construct, id: string) {
  super(scope, id);