Struct aws_sdk_iot::types::KafkaAction

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

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

Implementations

impl KafkaAction

pub fn destination_arn(&self) -> Option<&str>

The ARN of Kafka action's VPC TopicRuleDestination.

pub fn topic(&self) -> Option<&str>

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

pub fn key(&self) -> Option<&str>

The Kafka message key.

pub fn partition(&self) -> Option<&str>

The Kafka message partition.

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

Properties of the Apache Kafka producer client.

impl KafkaAction

pub fn builder() -> KafkaActionBuilder

Creates a new builder-style object to manufacture KafkaAction.

Trait Implementations

impl Clone for KafkaAction

fn clone(&self) -> KafkaAction

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for KafkaAction

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

Formats the value using the given formatter.

impl PartialEq<KafkaAction> for KafkaAction

fn eq(&self, other: &KafkaAction) -> 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 KafkaAction