Module kafka 

Available on crate feature kafka only.

Kafka is a distributed streaming platform.

This module provides a Kafka loader for Swiftide and allows you to ingest messages from Kafka topics and use them for RAG.

Can be configured with ClientConfig.

Example

let kafka = Kafka::builder()
    .client_config(ClientConfig::new())
    .topic("Hello Kafka")
    .build().unwrap();

Structs

ClientConfig

Client configuration.

Kafka

KafkaBuilder

Builder for Kafka.

Enums

KafkaBuilderError

Error type for KafkaBuilder