A high performant ingest engine for Kafka