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

Inherits:

Struct

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

Defined in:

gems/aws-sdk-iot/lib/aws-sdk-iot/types.rb

Overview

Note:

When making an API call, you may pass KafkaAction data as a hash:

{
  destination_arn: "AwsArn", # required
  topic: "String", # required
  key: "String",
  partition: "String",
  client_properties: { # required
    "String" => "String",
  },
}

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.

• #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 'gems/aws-sdk-iot/lib/aws-sdk-iot/types.rb', line 10682

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

#destination_arn ⇒ String

The ARN of Kafka action's VPC TopicRuleDestination.

Returns:

• (String)

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

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

#key ⇒ String

The Kafka message key.

Returns:

• (String)

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

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

#partition ⇒ String

The Kafka message partition.

Returns:

• (String)

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

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

#topic ⇒ String

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

Returns:

• (String)

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

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