interface KafkaActionProperty
Language | Type name |
---|---|
![]() | Amazon.CDK.AWS.IoT.CfnTopicRule.KafkaActionProperty |
![]() | software.amazon.awscdk.services.iot.CfnTopicRule.KafkaActionProperty |
![]() | aws_cdk.aws_iot.CfnTopicRule.KafkaActionProperty |
![]() | @aws-cdk/aws-iot » CfnTopicRule » KafkaActionProperty |
Send messages to an Amazon Managed Streaming for Apache Kafka (Amazon MSK) or self-managed Apache Kafka cluster.
Example
// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import * as iot from '@aws-cdk/aws-iot';
const kafkaActionProperty: iot.CfnTopicRule.KafkaActionProperty = {
clientProperties: {
clientPropertiesKey: 'clientProperties',
},
destinationArn: 'destinationArn',
topic: 'topic',
// the properties below are optional
key: 'key',
partition: 'partition',
};
Properties
Name | Type | Description |
---|---|---|
client | IResolvable | { [string]: string } | Properties of the Apache Kafka producer client. |
destination | string | The ARN of Kafka action's VPC TopicRuleDestination . |
topic | string | The Kafka topic for messages to be sent to the Kafka broker. |
key? | string | The Kafka message key. |
partition? | string | The Kafka message partition. |
clientProperties
Type:
IResolvable
| { [string]: string }
Properties of the Apache Kafka producer client.
destinationArn
Type:
string
The ARN of Kafka action's VPC TopicRuleDestination
.
topic
Type:
string
The Kafka topic for messages to be sent to the Kafka broker.
key?
Type:
string
(optional)
The Kafka message key.
partition?
Type:
string
(optional)
The Kafka message partition.