Használtál Kafka/RabbitMQ-t az adatfolyam feldolgozására a projektben? Mit csináltál pontosan?