Использовали ли Kafka/RabbitMQ для потоковой обработки данных на проекте? Что именно делали?

Укажите, какой брокер реально использовали, какие сообщения проходили и что делали лично. Отправка события, администрирование брокера и потоковая агрегация — разные виды опыта.

Приведите конкретный путь: источник, topic или очередь, потребитель и эффект. Расскажите про формат, ключи, повторы, обработку ошибок и наблюдаемость. Если реализовывали streaming, поясните окна, состояние и запоздавшие события; простое потребление сообщений не обязательно означает потоковую аналитику. Не приписывайте себе настройку кластера, если отвечали только за контракт интеграции.