AWSIoTKafkaAction

Objective-C

@interface AWSIoTKafkaAction

Swift

class AWSIoTKafkaAction

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

Required parameters: [destinationArn, topic, clientProperties]

  • Properties of the Apache Kafka producer client.

    Declaration

    Objective-C

    @property (nonatomic, strong) NSDictionary<NSString *, NSString *> *_Nullable clientProperties;

    Swift

    var clientProperties: [String : String]? { get set }

  • The ARN of Kafka action’s VPC TopicRuleDestination.

    Declaration

    Objective-C

    @property (nonatomic, strong) NSString *_Nullable destinationArn;

    Swift

    var destinationArn: String? { get set }

  • The list of Kafka headers that you specify.

    Declaration

    Objective-C

    @property (nonatomic, strong) NSArray<AWSIoTKafkaActionHeader *> *_Nullable headers;

    Swift

    var headers: [AWSIoTKafkaActionHeader]? { get set }
  • key

    The Kafka message key.

    Declaration

    Objective-C

    @property (nonatomic, strong) NSString *_Nullable key;

    Swift

    var key: String? { get set }

  • The Kafka message partition.

    Declaration

    Objective-C

    @property (nonatomic, strong) NSString *_Nullable partition;

    Swift

    var partition: String? { get set }

  • The Kafka topic for messages to be sent to the Kafka broker.

    Declaration

    Objective-C

    @property (nonatomic, strong) NSString *_Nullable topic;

    Swift

    var topic: String? { get set }