Kafka engine