Kafka Pipelines and Query Tuning