Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat(msk): support for Kafka version 3.8.x and add deprecated labels to legacy versions #33553

Merged
merged 4 commits into from
Feb 24, 2025
Merged

feat(msk): support for Kafka version 3.8.x and add deprecated labels to legacy versions #33553

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
4fcf9ec
feat(msk): add support for Kafka version 3.8.x and KRaft
mazyu36 Feb 22, 2025
e143d09
update
mazyu36 Feb 22, 2025
0a8a6c5
Merge branch 'main' into feature/msk-3-8
mazyu36 Feb 24, 2025
c547150
Merge branch 'main' into feature/msk-3-8
mergify[bot] Feb 24, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 13 additions & 0 deletions packages/@aws-cdk/aws-msk-alpha/lib/cluster-version.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -169,6 +169,19 @@ export class KafkaVersion {
*/
public static readonly V3_7_X_KRAFT = KafkaVersion.of('3.7.x.kraft', { tieredStorage: true });

/**
* Kafka version 3.8.x with ZooKeeper metadata mode support
*
* @see https://docs.aws.amazon.com/msk/latest/developerguide/metadata-management.html#msk-get-connection-string
*/
public static readonly V3_8_X = KafkaVersion.of('3.8.x', { tieredStorage: true });

/**
* Kafka version 3.8.x with KRaft (Apache Kafka Raft) metadata mode support
*
* @see https://docs.aws.amazon.com/msk/latest/developerguide/metadata-management.html#kraft-intro
*/
public static readonly V3_8_X_KRAFT = KafkaVersion.of('3.8.x.kraft', { tieredStorage: true });
/**
* Custom cluster version
* @param version custom version number
Expand Down
2 changes: 2 additions & 0 deletions packages/@aws-cdk/aws-msk-alpha/test/cluster.test.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -47,6 +47,8 @@ describe('MSK Cluster', () => {
[msk.KafkaVersion.V3_6_0, '3.6.0'],
[msk.KafkaVersion.V3_7_X, '3.7.x'],
[msk.KafkaVersion.V3_7_X_KRAFT, '3.7.x.kraft'],
[msk.KafkaVersion.V3_8_X, '3.8.x'],
[msk.KafkaVersion.V3_8_X_KRAFT, '3.8.x.kraft'],
],
)('created with expected Kafka version %j', (parameter, result) => {
new msk.Cluster(stack, 'Cluster', {
Expand Down
2 changes: 2 additions & 0 deletions packages/@aws-cdk/aws-msk-alpha/test/integ.cluster-version.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,8 @@ const versions: KafkaVersion[] = [
KafkaVersion.V3_6_0,
KafkaVersion.V3_7_X,
KafkaVersion.V3_7_X_KRAFT,
KafkaVersion.V3_8_X,
KafkaVersion.V3_8_X_KRAFT,
];

class KafkaVersionTest extends Stack {
Expand Down
Loading