interface KafkaActionProperty

Language	Type name
.NET	`Amazon.CDK.AWS.IoT.CfnTopicRule.KafkaActionProperty`
Go	`github.com/aws/aws-cdk-go/awscdk/v2/awsiot#CfnTopicRule_KafkaActionProperty`
Java	`software.amazon.awscdk.services.iot.CfnTopicRule.KafkaActionProperty`
Python	`aws_cdk.aws_iot.CfnTopicRule.KafkaActionProperty`
TypeScript	`aws-cdk-lib` » `aws_iot` » `CfnTopicRule` » `KafkaActionProperty`

Send messages to an Amazon Managed Streaming for Apache Kafka (Amazon MSK) or self-managed Apache Kafka cluster.

See also: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-iot-topicrule-kafkaaction.html

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-lib';
const kafkaActionProperty: iot.CfnTopicRule.KafkaActionProperty = {
  clientProperties: {
    clientPropertiesKey: 'clientProperties',
  },
  destinationArn: 'destinationArn',
  topic: 'topic',

  // the properties below are optional
  headers: [{
    key: 'key',
    value: 'value',
  }],
  key: 'key',
  partition: 'partition',
};

Properties

Name	Type	Description
clientProperties	`{ [string]: string } \|` `IResolvable`	Properties of the Apache Kafka producer client.
destinationArn	`string`	The ARN of Kafka action's VPC `TopicRuleDestination` .
topic	`string`	The Kafka topic for messages to be sent to the Kafka broker.
headers?	`IResolvable` `\| (IResolvable` `\|` `KafkaActionHeaderProperty)[]`	The list of Kafka headers that you specify.
key?	`string`	The Kafka message key.
partition?	`string`	The Kafka message partition.