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

ログインしていません。 ログイン 回答を投稿する。

優れた回答とは、質問に明確に答え、建設的なフィードバックを提供し、質問者の専門分野におけるスキルの向上を促すものです。

質問に答えるためのガイドライン

関連するコンテンツ