Managed Kafka streaming with AWS KinesisPython
Given your goal, the ideal resource to use will be
aws.kinesis.Stream, as it is the Pulumi resource specifically designed for managing AWS Kinesis Data Streams.
Here is a description of your program. This Pulumi program will create and manage an AWS Kinesis stream named 'kafka-stream'.
Links to the resources used in the Pulumi Registry:
The Python program that accomplishes your goal is as follows:
Please replace the
kms_key_idwith your own value if you are not using the default AWS managed key.
This program creates a Kinesis stream with a 24-hour data retention period and a single shard. It uses Key Management Service (KMS) for server-side encryption. The name of the Kinesis stream is exported as 'kafka_stream'.