Producer публикует записи в топики; consumer читает записи из топиков (обычно в составе consumer group) и обрабатывает их.
Разбор
- Продюсер выбирает топик, ключ, значение, иногда headers.
- Консьюмер коммитит offsets — прогресс чтения.
- Один поток данных обслуживает много независимых приложений-читателей.
- Клиентские библиотеки (Java, librdkafka) реализуют протоколы.
Итог
Producer пишет в лог; consumer читает и двигает offset.
