msk_demo:使用AWS CDK设置AWS MSK集群 源码

AWS MSK演示 使用子网创建VPC 创建一个Kafka集群,每个子网中都有一个代理 创建可以连接到Kafka集群的EC2实例 CDK堆栈本身利用了两个环境变量 CDK_DEFAULT_REGION CDK_DEFAULT_ACCOUNT 这些应该在执行cdk deploy之前在命令行上设置。 Kafka客户端设置 我们从在其中一个子网中运行的EC2实例连接到Kafka群集。 在能够创建主题和发送消息之前,需要一些基本步骤。 安装Java sudo su - yum install -y java 安装Kafka客户端 wget https://archive.apache.org/