Interface CfnTopicRule.KafkaActionProperty

All Superinterfaces:
software.amazon.jsii.JsiiSerializable
All Known Implementing Classes:
CfnTopicRule.KafkaActionProperty.Jsii$Proxy
Enclosing class:
CfnTopicRule

@Stability(Stable) public static interface CfnTopicRule.KafkaActionProperty extends software.amazon.jsii.JsiiSerializable
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 software.amazon.awscdk.services.iot.*;
 KafkaActionProperty kafkaActionProperty = KafkaActionProperty.builder()
         .clientProperties(Map.of(
                 "clientPropertiesKey", "clientProperties"))
         .destinationArn("destinationArn")
         .topic("topic")
         // the properties below are optional
         .key("key")
         .partition("partition")
         .build();
 
  • Method Details

    • getClientProperties

      @Stability(Stable) @NotNull Object getClientProperties()
      Properties of the Apache Kafka producer client.
    • getDestinationArn

      @Stability(Stable) @NotNull String getDestinationArn()
      The ARN of Kafka action's VPC TopicRuleDestination .
    • getTopic

      @Stability(Stable) @NotNull String getTopic()
      The Kafka topic for messages to be sent to the Kafka broker.
    • getKey

      @Stability(Stable) @Nullable default String getKey()
      The Kafka message key.
    • getPartition

      @Stability(Stable) @Nullable default String getPartition()
      The Kafka message partition.
    • builder

      @Stability(Stable) static CfnTopicRule.KafkaActionProperty.Builder builder()
      Returns:
      a CfnTopicRule.KafkaActionProperty.Builder of CfnTopicRule.KafkaActionProperty