Struct KafkaAction

#[non_exhaustive]
pub struct KafkaAction {
    pub destination_arn: String,
    pub topic: String,
    pub key: Option<String>,
    pub partition: Option<String>,
    pub client_properties: HashMap<String, String>,
    pub headers: Option<Vec<KafkaActionHeader>>,
}

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

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

destination_arn: String

The ARN of Kafka action's VPC TopicRuleDestination.

topic: String

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

key: Option<String>

The Kafka message key.

partition: Option<String>

The Kafka message partition.

client_properties: HashMap<String, String>

Properties of the Apache Kafka producer client.

headers: Option<Vec<KafkaActionHeader>>

The list of Kafka headers that you specify.

Implementations

impl KafkaAction

pub fn destination_arn(&self) -> &str

The ARN of Kafka action's VPC TopicRuleDestination.

pub fn topic(&self) -> &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) -> &HashMap<String, String>

Properties of the Apache Kafka producer client.

pub fn headers(&self) -> &[KafkaActionHeader]

The list of Kafka headers that you specify.

If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use .headers.is_none().

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 duplicate of the value.

const 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 for KafkaAction

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl StructuralPartialEq for KafkaAction