[astrocyte.ingest_stream_drivers]
kafka = astrocyte_ingestion_kafka.source:KafkaStreamIngestSource
