CDK constructs for Kinesis Delivery stream to consume from MSK topic

0

As of Sept, 2023 kinesis firehose supports creating delivery stream to consume MSK Topic data and store that into s3 with partitioning. https://aws.amazon.com/about-aws/whats-new/2023/09/amazon-msk-data-s3-kinesis-data-firehose/ Is there a way to configure this in CDK as well ? Looking for some examples. Thanks

已提问 3 个月前344 查看次数
1 回答
0

Create a MSK cluster using the MskConstruct:

const cluster = new Msk.Cluster(this, 'MyCluster', {
  // configuration 
});
Create a Firehose delivery stream using the FirehoseConstruct and specify the MSK cluster as the source:

const stream = new Firehose.CfnDeliveryStream(this, 'MyStream', {
  deliveryStreamType: 'KinesisStreamAsSource',
  kinesisStreamSourceConfiguration: {
    kinesisStreamArn: cluster.kinesisStreamArn,
    roleArn: // IAM role 
  }
});

Specify the S3 destination configuration for the stream.

Add appropriate IAM permissions and roles.

Deploy the CDK app.

profile picture
专家
已回答 3 个月前
  • There is no property in MSK cluster called :- cluster.kinesisStreamArn

您未登录。 登录 发布回答。

一个好的回答可以清楚地解答问题和提供建设性反馈,并能促进提问者的职业发展。

回答问题的准则