Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Appearance settings

Commit 6317518

Browse filesBrowse files
authored
feat(msk): Kafka version 3.4.0 (#25557)
Closes #25522 ---- *By submitting this pull request, I confirm that my contribution is made under the terms of the Apache-2.0 license*
1 parent d7e263d commit 6317518
Copy full SHA for 6317518

11 files changed

+4820
-0
lines changed

‎packages/@aws-cdk/aws-msk-alpha/lib/cluster-version.ts

Copy file name to clipboardExpand all lines: packages/@aws-cdk/aws-msk-alpha/lib/cluster-version.ts
+6Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -95,6 +95,12 @@ export class KafkaVersion {
9595
* Kafka version 3.3.2
9696
*/
9797
public static readonly V3_3_2 = KafkaVersion.of('3.3.2');
98+
99+
/**
100+
* Kafka version 3.4.0
101+
*/
102+
public static readonly V3_4_0 = KafkaVersion.of('3.4.0');
103+
98104
/**
99105
* Custom cluster version
100106
* @param version custom version number

‎packages/@aws-cdk/aws-msk-alpha/test/cluster.test.ts

Copy file name to clipboardExpand all lines: packages/@aws-cdk/aws-msk-alpha/test/cluster.test.ts
+1Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,7 @@ describe('MSK Cluster', () => {
4141
[msk.KafkaVersion.V3_2_0, '3.2.0'],
4242
[msk.KafkaVersion.V3_3_1, '3.3.1'],
4343
[msk.KafkaVersion.V3_3_2, '3.3.2'],
44+
[msk.KafkaVersion.V3_4_0, '3.4.0'],
4445
],
4546
)('created with expected Kafka version %j', (parameter, result) => {
4647
new msk.Cluster(stack, 'Cluster', {
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,19 @@
1+
{
2+
"version": "31.0.0",
3+
"files": {
4+
"21fbb51d7b23f6a6c262b46a9caee79d744a3ac019fd45422d988b96d44b2a22": {
5+
"source": {
6+
"path": "KafkaVersionIntegTestDefaultTestDeployAssertD6628743.template.json",
7+
"packaging": "file"
8+
},
9+
"destinations": {
10+
"current_account-current_region": {
11+
"bucketName": "cdk-hnb659fds-assets-${AWS::AccountId}-${AWS::Region}",
12+
"objectKey": "21fbb51d7b23f6a6c262b46a9caee79d744a3ac019fd45422d988b96d44b2a22.json",
13+
"assumeRoleArn": "arn:${AWS::Partition}:iam::${AWS::AccountId}:role/cdk-hnb659fds-file-publishing-role-${AWS::AccountId}-${AWS::Region}"
14+
}
15+
}
16+
}
17+
},
18+
"dockerImages": {}
19+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,36 @@
1+
{
2+
"Parameters": {
3+
"BootstrapVersion": {
4+
"Type": "AWS::SSM::Parameter::Value<String>",
5+
"Default": "/cdk-bootstrap/hnb659fds/version",
6+
"Description": "Version of the CDK Bootstrap resources in this environment, automatically retrieved from SSM Parameter Store. [cdk:skip]"
7+
}
8+
},
9+
"Rules": {
10+
"CheckBootstrapVersion": {
11+
"Assertions": [
12+
{
13+
"Assert": {
14+
"Fn::Not": [
15+
{
16+
"Fn::Contains": [
17+
[
18+
"1",
19+
"2",
20+
"3",
21+
"4",
22+
"5"
23+
],
24+
{
25+
"Ref": "BootstrapVersion"
26+
}
27+
]
28+
}
29+
]
30+
},
31+
"AssertDescription": "CDK bootstrap stack version 6 required. Please run 'cdk bootstrap' with a recent version of the CDK CLI."
32+
}
33+
]
34+
}
35+
}
36+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,19 @@
1+
{
2+
"version": "31.0.0",
3+
"files": {
4+
"60dae11a2659444f952ba2b102ea25cba4d75ba7229c89d74c55973e2c5c5b35": {
5+
"source": {
6+
"path": "KafkaVersionTestStack.template.json",
7+
"packaging": "file"
8+
},
9+
"destinations": {
10+
"current_account-current_region": {
11+
"bucketName": "cdk-hnb659fds-assets-${AWS::AccountId}-${AWS::Region}",
12+
"objectKey": "60dae11a2659444f952ba2b102ea25cba4d75ba7229c89d74c55973e2c5c5b35.json",
13+
"assumeRoleArn": "arn:${AWS::Partition}:iam::${AWS::AccountId}:role/cdk-hnb659fds-file-publishing-role-${AWS::AccountId}-${AWS::Region}"
14+
}
15+
}
16+
}
17+
},
18+
"dockerImages": {}
19+
}

0 commit comments

Comments
0 (0)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.