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

Inherits:
Struct
  • Object
show all
Defined in:
gems/aws-sdk-iot/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 collapse

SENSITIVE =
[]

Instance Attribute Summary collapse

Instance Attribute Details

#client_propertiesHash<String,String>

Properties of the Apache Kafka producer client.

Returns:

  • (Hash<String,String>)


8891
8892
8893
8894
8895
8896
8897
8898
8899
8900
# File 'gems/aws-sdk-iot/lib/aws-sdk-iot/types.rb', line 8891

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

#destination_arnString

The ARN of Kafka action's VPC TopicRuleDestination.

Returns:

  • (String)


8891
8892
8893
8894
8895
8896
8897
8898
8899
8900
# File 'gems/aws-sdk-iot/lib/aws-sdk-iot/types.rb', line 8891

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

#headersArray<Types::KafkaActionHeader>

The list of Kafka headers that you specify.

Returns:



8891
8892
8893
8894
8895
8896
8897
8898
8899
8900
# File 'gems/aws-sdk-iot/lib/aws-sdk-iot/types.rb', line 8891

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

#keyString

The Kafka message key.

Returns:

  • (String)


8891
8892
8893
8894
8895
8896
8897
8898
8899
8900
# File 'gems/aws-sdk-iot/lib/aws-sdk-iot/types.rb', line 8891

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

#partitionString

The Kafka message partition.

Returns:

  • (String)


8891
8892
8893
8894
8895
8896
8897
8898
8899
8900
# File 'gems/aws-sdk-iot/lib/aws-sdk-iot/types.rb', line 8891

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

#topicString

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

Returns:

  • (String)


8891
8892
8893
8894
8895
8896
8897
8898
8899
8900
# File 'gems/aws-sdk-iot/lib/aws-sdk-iot/types.rb', line 8891

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