Module kafka

Re-exports

pub use enumerator::*;

pub use source::*;

pub use split::*;

Modules

client_context 🔒

enumerator

private_link

source

split

stats

Structs

KafkaContextCommon

KafkaProperties

RdKafkaPropertiesConsumer

Properties for the rdkafka library. Leave a field as None to use the default value. These properties are not intended to be exposed to users in the majority of cases.

RwConsumerContext

Kafka consumer context used for private link, IAM auth, and metrics

RwProducerContext

Kafka producer context used for private link, IAM auth, and metrics

Constants

KAFKA_CONNECTOR

KAFKA_ISOLATION_LEVEL 🔒

KAFKA_PROPS_BROKER_KEY

KAFKA_PROPS_BROKER_KEY_ALIAS

PRIVATELINK_CONNECTION

Type Aliases

BoxConsumerContext