Kafka producers/consumers were replaced with web API frameworks (FastAPI + uvicorn) supporting async requests. Added/updated libraries for fast JSON parsing and data modelling.
Added logging support for viewing status in containers/eventual support with FileBeats input plugin for Logstash + ES.
Switching Kafka implementations to HTTP in Ingestor Service.