На странице собраны вопросы по Kafka — от проверки базовых принципов до практического применения и архитектурных решений. В подборке чаще встречаются темы: kafka, backend, api.
В синхронной цепочке вызовов обычно каждый следующий компонент вызывается предыдущим, формируя последовательный поток выполнения. Например, в бизнес-процессе расчёта цены заказа:
Backpressure в Kafka — это механизм контроля нагрузки, который позволяет потребителям (consumers) и продюсерам (producers) регулировать скорость обработки и отправки сообщений, чтобы избежать перегрузки системы.
В Apache Kafka сообщения не удаляются сразу после публикации, так как Kafka спроектирована как распределённый журнал событий с возможностью хранения истории сообщений.
В стандартном сценарии Kafka Producer не ждет Consumer'а, так как они работают асинхронно: Producer отправляет сообщения в топик, а Consumer читает их независимо.
В Kafka, если у нас есть топик с 3 партициями и 4 консюмера, каждый из которых находится в своей отдельной consumer group, то каждый консюмер будет читать все сообщения из всех 3 партиций независимо друг от друга.