Какая компонента отвечает за установление связи и регистрацию между Kafka-брокерами?
В Kafka за установление связи и регистрацию между брокерами отвечает компонент ZooKeeper.
Читать ответПодготовка к интервью
715 вопросов по Kafka с технических собеседований
Что проверяют на интервью
На странице собраны вопросы по Kafka — от проверки базовых принципов до практического применения и архитектурных решений. В подборке чаще встречаются темы: kafka, backend, api.
Каталог
В Kafka за установление связи и регистрацию между брокерами отвечает компонент ZooKeeper.
Читать ответКлюч партиционирования в Kafka нужен для определения, в какую партицию топика попадёт конкретное сообщение. Это важно для обеспечения порядка сообщений с одинаковым ключом и балансировки нагрузки между партициями.
Читать ответЕсли при обработке сообщения из Kafka в приложении выбрасывается исключение, но само приложение не падает, то поведение зависит от способа обработки и настроек потребителя:
Читать ответДля взаимодействия с Kafka на языке Go часто используется библиотека Shopify/sarama. Это популярный и хорошо поддерживаемый клиент Kafka для Go, который предоставляет полный набор функций для продюсеров и консьюмеров.
Читать ответПоток событий в системах часто получают через Kafka, так как это надёжный брокер сообщений для асинхронной передачи данных.
Читать ответЧтобы 100 инстансов приложения с 10 потоками каждый эффективно работали с Kafka и не блокировали друг друга, нужно правильно спроектировать топики и партиции.
Читать ответДля реализации функции Pipe с параллельной обработкой чтения, записи и подтверждения прогресса можно использовать каналы и горутины. Идея:
Читать ответKafka стоит использовать для обмена сообщениями между микросервисами, когда требуется:
Читать ответKafka и RabbitMQ — это системы обмена сообщениями, но с разной архитектурой и предназначением.
Читать ответВ Apache Kafka сообщения направляются в топики, а потребители (Consumers) читают их из этих топиков.
Читать ответТакое поведение обычно связано с тем, что сообщения в Kafka могут попадать в разные партиции и потребители читают их параллельно, из-за чего порядок доставки не гарантируется между разными ключами или партициями.
Читать ответВ проектах на Golang я использовал Kafka для организации высоконагруженных систем обмена сообщениями.
Читать ответ