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

Inherits:
Struct
  • Object
show all
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 collapse

SENSITIVE =
[]

Instance Attribute Summary collapse

Instance Attribute Details

#client_propertiesHash<String,String>

Properties of the Apache Kafka producer client.

Returns:

  • (Hash<String,String>)


10610
10611
10612
10613
10614
10615
10616
10617
10618
# File 'gems/aws-sdk-iot/lib/aws-sdk-iot/types.rb', line 10610

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

#destination_arnString

The ARN of Kafka action's VPC TopicRuleDestination.

Returns:

  • (String)


10610
10611
10612
10613
10614
10615
10616
10617
10618
# File 'gems/aws-sdk-iot/lib/aws-sdk-iot/types.rb', line 10610

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

#keyString

The Kafka message key.

Returns:

  • (String)


10610
10611
10612
10613
10614
10615
10616
10617
10618
# File 'gems/aws-sdk-iot/lib/aws-sdk-iot/types.rb', line 10610

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

#partitionString

The Kafka message partition.

Returns:

  • (String)


10610
10611
10612
10613
10614
10615
10616
10617
10618
# File 'gems/aws-sdk-iot/lib/aws-sdk-iot/types.rb', line 10610

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

#topicString

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

Returns:

  • (String)


10610
10611
10612
10613
10614
10615
10616
10617
10618
# File 'gems/aws-sdk-iot/lib/aws-sdk-iot/types.rb', line 10610

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