Class: Aws::IoT::Types::KafkaAction

Inherits:

Struct

• Object
• Struct
• Aws::IoT::Types::KafkaAction

Includes:

Structure

Defined in:

lib/aws-sdk-iot/types.rb

Overview

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

Constant Summary

SENSITIVE =

[]

Instance Attribute Summary

• #client_properties ⇒ Hash<String,String>

  Properties of the Apache Kafka producer client.

• #destination_arn ⇒ String

  The ARN of Kafka action’s VPC ‘TopicRuleDestination`.

• #headers ⇒ Array<Types::KafkaActionHeader>

  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.

Instance Attribute Details

#client_properties ⇒ Hash<String,String>

Properties of the Apache Kafka producer client.

Returns:

• (Hash<String,String>)

# File 'lib/aws-sdk-iot/types.rb', line 9216

class KafkaAction < Struct.new(
  :destination_arn,
  :topic,
  :key,
  :partition,
  :client_properties,
  :headers)
  SENSITIVE = []
  include Aws::Structure
end

#destination_arn ⇒ String

The ARN of Kafka action’s VPC ‘TopicRuleDestination`.

Returns:

• (String)

# File 'lib/aws-sdk-iot/types.rb', line 9216

class KafkaAction < Struct.new(
  :destination_arn,
  :topic,
  :key,
  :partition,
  :client_properties,
  :headers)
  SENSITIVE = []
  include Aws::Structure
end

#headers ⇒ Array<Types::KafkaActionHeader>

The list of Kafka headers that you specify.

Returns:

• (Array<Types::KafkaActionHeader>)

# File 'lib/aws-sdk-iot/types.rb', line 9216

class KafkaAction < Struct.new(
  :destination_arn,
  :topic,
  :key,
  :partition,
  :client_properties,
  :headers)
  SENSITIVE = []
  include Aws::Structure
end

#key ⇒ String

The Kafka message key.

Returns:

• (String)

# File 'lib/aws-sdk-iot/types.rb', line 9216

class KafkaAction < Struct.new(
  :destination_arn,
  :topic,
  :key,
  :partition,
  :client_properties,
  :headers)
  SENSITIVE = []
  include Aws::Structure
end

#partition ⇒ String

The Kafka message partition.

Returns:

• (String)

# File 'lib/aws-sdk-iot/types.rb', line 9216

class KafkaAction < Struct.new(
  :destination_arn,
  :topic,
  :key,
  :partition,
  :client_properties,
  :headers)
  SENSITIVE = []
  include Aws::Structure
end

#topic ⇒ String

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

Returns:

• (String)

# File 'lib/aws-sdk-iot/types.rb', line 9216

class KafkaAction < Struct.new(
  :destination_arn,
  :topic,
  :key,
  :partition,
  :client_properties,
  :headers)
  SENSITIVE = []
  include Aws::Structure
end