in amazon-msk-java-app-cdk/lib/kafka-stack.ts [27:46]
constructor(vpcStack: VpcStack, scope: cdk.Construct, id: string, props?: cdk.StackProps) {
super(scope, id, props);
this.kafkaCluster = new msk.CfnCluster(this, "kafkaCluster", {
brokerNodeGroupInfo: {
securityGroups: [vpcStack.kafkaSecurityGroup.securityGroupId],
clientSubnets: [...vpcStack.vpc.selectSubnets({
subnetType: ec2.SubnetType.PRIVATE
}).subnetIds],
instanceType: "kafka.t3.small",
storageInfo: {
ebsStorageInfo: {
volumeSize: 5
}
}
},
clusterName: "TransactionsKafkaCluster",
kafkaVersion: "2.7.0",
numberOfBrokerNodes: 2
});
}