in cdk/src/main/java/com/amazonaws/services/kinesisanalytics/AmazonKinesisDataAnalyticsApacheFlinkServerSentEventsSseCdkStack.java [136:142]
private void createKinesisDataStream() {
outputDataStream = Stream.Builder.create(this, "KinesisServerSentEventsDataStream")
.shardCount(1)
.retentionPeriod(Duration.hours(24))
.encryption(StreamEncryption.UNENCRYPTED)
.build();
}