import * as events from 'aws-cdk-lib/aws-events';
import * as event_targets from 'aws-cdk-lib/aws-events-targets';
import * as sqs from 'aws-cdk-lib/aws-sqs';
import * as kinesis from 'aws-cdk-lib/aws-kinesis';

// Create Stream and DLQ
const myKinesisStream = new kinesis.Stream(this, 'MyKinesisStream', {
    streamName: 'my-kinesis-stream',
    streamMode: kinesis.StreamMode.ON_DEMAND,
});
const myDeadLetterQueue = new sqs.Queue(this, 'MyDeadLetterQueue');

// Kinesis Target created with DLQ configured
const myKinesisTarget = new event_targets.KinesisStream(myKinesisStream, {deadLetterQueue: myDeadLetterQueue});


// Example Target Use-case: Connecting EventBus to Kinesis Stream now has DLQ
const myEventBus = new events.EventBus(this, 'MyEventBus', { eventBusName: 'my-event-bus'});

const myEventRule = new events.Rule(this, 'MyEventRule', {
    eventBus: myEventBus,
    eventPattern: ['pattern'],
    targets: [myKinesisTarget],
});