Git-Mirrors/backend-and-orchestration-toolkit
1
0
Fork 0
mirror of https://github.com/autistic-symposium/backend-and-orchestration-toolkit.git synced 2025-11-23 14:51:28 -05:00
Code Issues Projects Releases Packages Wiki Activity
backend-and-orchestration-t.../code/kubernetes/python-cdk/ts/MSK_example
History
Exact
autistic-symposium-helper 2a6449bb85
merge files from the blockchain infra repo (#59)
2024-11-17 17:03:20 -08:00
..
bin merge files from the blockchain infra repo (#59) 2024-11-17 17:03:20 -08:00
lib merge files from the blockchain infra repo (#59) 2024-11-17 17:03:20 -08:00
cdk.context.json merge files from the blockchain infra repo (#59) 2024-11-17 17:03:20 -08:00
cdk.json merge files from the blockchain infra repo (#59) 2024-11-17 17:03:20 -08:00
package-lock.json merge files from the blockchain infra repo (#59) 2024-11-17 17:03:20 -08:00
package.json merge files from the blockchain infra repo (#59) 2024-11-17 17:03:20 -08:00
README.md merge files from the blockchain infra repo (#59) 2024-11-17 17:03:20 -08:00
tsconfig.json merge files from the blockchain infra repo (#59) 2024-11-17 17:03:20 -08:00

README.md

CDK MSK Example

Deploy VPC

Amazon VPC lets you provision a logically isolated section of the AWS Cloud where you can all the resources as in a virtual network.

These are the default values in cdk.json:

"vpc.cidr": "10.0.0.0/16",
"vpc.maxAzs": 3,

Deploy with:

cdk deploy VPCStack

Deploy MSK

Amazon MSK is a managed service that makes it easy for you to build and run applications that use Apache Kafka to process streaming data.

These are the default values in cdk.json:

"msk.DevMskCluster": "MskCluster",
"msk.ClusterTag": "MSK cluster",
"msk.brokerNodeGroupBrokerAzDistribution": "DEFAULT",
"msk.enhancedMonitoring": "PER_BROKER",
"msk.brokerNodeGroupEBSVolumeSize": 100,
"msk.brokerNodeGroupInstanceType": "kafka.m5.large",
"msk.brokerPort": 9092,
"msk.kafkaVersion": "2.2.1",
"msk.numberOfBrokerNodes": 3

Deploy with:

cdk deploy MskClusterStack

Kafka CLI

Note that the CLI commands for MKS are given by the keyword kafka, for example:

aws kafka list-clusters

To retrieve BootstrapBrokerStringTls, run:

 aws kafka get-bootstrap-brokers --cluster-arn <cluster ARN>

However, access and development within the cluster (e.g. creating topics, accessing brokers) need to be done while connected to the VPN.