API reference¶
The full public surface of minikafka. All entries are auto-generated
from the docstrings in src/minikafka/core.py.
| Symbol | Page |
|---|---|
Source |
The SQLite-backed entry point. |
Topic |
Typed, append-only queue. |
Pipeline |
Single-source transformation. |
FullPipeline |
Multi-pipeline DAG runner. |
Record |
Stored-message wrapper with metadata. |
| Exceptions | MinikafkaError and friends. |