Skip to main content

Documentation Index

Fetch the complete documentation index at: https://docs.datris.ai/llms.txt

Use this file to discover all available pages before exploring further.

Location: examples/kafka-csv-loader/ A Kafka producer utility that publishes CSV file contents to Kafka topics. Use this to ingest data into the pipeline via Kafka streaming instead of the file upload API.

Setup

cd examples/kafka-csv-loader
pip install kafka-python

Run

python app.py

Configuration

Edit app.py to configure:
  • Kafka broker address
  • Topic name
  • CSV file path
See Kafka Ingestion for how to configure pipelines with Kafka sources.