Struct aws_sdk_iot::types::builders::KafkaActionBuilder

#[non_exhaustive]
pub struct KafkaActionBuilder { /* private fields */ }

A builder for KafkaAction.

Implementations

impl KafkaActionBuilder

pub fn destination_arn(self, input: impl Into<String>) -> Self

The ARN of Kafka action's VPC TopicRuleDestination.

This field is required.

pub fn set_destination_arn(self, input: Option<String>) -> Self

The ARN of Kafka action's VPC TopicRuleDestination.

pub fn get_destination_arn(&self) -> &Option<String>

The ARN of Kafka action's VPC TopicRuleDestination.

pub fn topic(self, input: impl Into<String>) -> Self

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

This field is required.

pub fn set_topic(self, input: Option<String>) -> Self

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

pub fn get_topic(&self) -> &Option<String>

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

pub fn key(self, input: impl Into<String>) -> Self

The Kafka message key.

pub fn set_key(self, input: Option<String>) -> Self

The Kafka message key.

pub fn get_key(&self) -> &Option<String>

The Kafka message key.

pub fn partition(self, input: impl Into<String>) -> Self

The Kafka message partition.

pub fn set_partition(self, input: Option<String>) -> Self

The Kafka message partition.

pub fn get_partition(&self) -> &Option<String>

The Kafka message partition.

pub fn client_properties( self, k: impl Into<String>, v: impl Into<String> ) -> Self

Adds a key-value pair to client_properties.

To override the contents of this collection use set_client_properties.

Properties of the Apache Kafka producer client.

pub fn set_client_properties( self, input: Option<HashMap<String, String>> ) -> Self

Properties of the Apache Kafka producer client.

pub fn get_client_properties(&self) -> &Option<HashMap<String, String>>

Properties of the Apache Kafka producer client.

pub fn headers(self, input: KafkaActionHeader) -> Self

Appends an item to headers.

To override the contents of this collection use set_headers.

The list of Kafka headers that you specify.

pub fn set_headers(self, input: Option<Vec<KafkaActionHeader>>) -> Self

The list of Kafka headers that you specify.

pub fn get_headers(&self) -> &Option<Vec<KafkaActionHeader>>

The list of Kafka headers that you specify.

pub fn build(self) -> Result<KafkaAction, BuildError>

Consumes the builder and constructs a KafkaAction. This method will fail if any of the following fields are not set:

• destination_arn
• topic
• client_properties

Trait Implementations

impl Clone for KafkaActionBuilder

fn clone(&self) -> KafkaActionBuilder

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for KafkaActionBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for KafkaActionBuilder

fn default() -> KafkaActionBuilder

Returns the “default value” for a type.

impl PartialEq for KafkaActionBuilder

fn eq(&self, other: &KafkaActionBuilder) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for KafkaActionBuilder