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