interface KafkaActionProperty
| Language | Type name |
|---|---|
.NET | Amazon.CDK.CfnPropertyMixins.AWS.IoT.CfnTopicRulePropsMixin.KafkaActionProperty |
Go | github.com/aws/aws-cdk-go/awscdkcfnpropertymixins/v2/awsiot#CfnTopicRulePropsMixin_KafkaActionProperty |
Java | software.amazon.awscdk.cfnpropertymixins.services.iot.CfnTopicRulePropsMixin.KafkaActionProperty |
Python | aws_cdk.cfn_property_mixins.aws_iot.CfnTopicRulePropsMixin.KafkaActionProperty |
TypeScript | @aws-cdk/cfn-property-mixins » aws_iot » CfnTopicRulePropsMixin » 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 { aws_iot as iot } from '@aws-cdk/cfn-property-mixins';
const kafkaActionProperty: iot.CfnTopicRulePropsMixin.KafkaActionProperty = {
clientProperties: {
clientPropertiesKey: 'clientProperties',
},
destinationArn: 'destinationArn',
headers: [{
key: 'key',
value: 'value',
}],
key: 'key',
partition: 'partition',
topic: 'topic',
};
Properties
| Name | Type | Description |
|---|---|---|
| client | { [string]: string } | IResolvable | Properties of the Apache Kafka producer client. |
| destination | string | The ARN of Kafka action's VPC TopicRuleDestination . |
| headers? | IResolvable | (IResolvable | Kafka)[] | The list of Kafka headers that you specify. |
| key? | string | The Kafka message key. |
| partition? | string | The Kafka message partition. |
| topic? | string | The Kafka topic for messages to be sent to the Kafka broker. |
clientProperties?
Type:
{ [string]: string } | IResolvable
(optional)
Properties of the Apache Kafka producer client.
destinationArn?
Type:
string
(optional)
The ARN of Kafka action's VPC TopicRuleDestination .
headers?
Type:
IResolvable | (IResolvable | Kafka)[]
(optional)
The list of Kafka headers that you specify.
key?
Type:
string
(optional)
The Kafka message key.
partition?
Type:
string
(optional)
The Kafka message partition.
topic?
Type:
string
(optional)
The Kafka topic for messages to be sent to the Kafka broker.

.NET
Go
Java
Python
TypeScript