interface KafkaActionProperty
| Language | Type name |
|---|---|
.NET | Amazon.CDK.Mixins.Preview.AWS.IoT.Mixins.CfnTopicRulePropsMixin.KafkaActionProperty |
Go | github.com/aws/aws-cdk-go/awscdkmixinspreview/v2/awsiot/mixins#CfnTopicRulePropsMixin_KafkaActionProperty |
Java | software.amazon.awscdk.mixins.preview.services.iot.mixins.CfnTopicRulePropsMixin.KafkaActionProperty |
Python | aws_cdk.mixins_preview.aws_iot.mixins.CfnTopicRulePropsMixin.KafkaActionProperty |
TypeScript | @aws-cdk/mixins-preview » aws_iot » mixins » 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 { mixins as iot_mixins } from '@aws-cdk/mixins-preview/aws-iot';
const kafkaActionProperty: iot_mixins.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