Struct KafkaActionHeader

#[non_exhaustive]
pub struct KafkaActionHeader {
    pub key: String,
    pub value: String,
}

Specifies a Kafka header using key-value pairs when you create a Rule’s Kafka Action. You can use these headers to route data from IoT clients to downstream Kafka clusters without modifying your message payload.

For more information about Rule's Kafka action, see Apache Kafka.

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.

key: String

The key of the Kafka header.

value: String

The value of the Kafka header.

Implementations

impl KafkaActionHeader

pub fn key(&self) -> &str

The key of the Kafka header.

pub fn value(&self) -> &str

The value of the Kafka header.

impl KafkaActionHeader

pub fn builder() -> KafkaActionHeaderBuilder

Creates a new builder-style object to manufacture KafkaActionHeader.

Trait Implementations

impl Clone for KafkaActionHeader

fn clone(&self) -> KafkaActionHeader

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KafkaActionHeader

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

Formats the value using the given formatter.

impl PartialEq for KafkaActionHeader

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