У меня есть группа потребителей kafka, работающая на node.js и работающая на node-kafka. Когда эта...

Я упрощаю свою проблему по следующему сценарию: 3 друга делят карту лояльности. Карта имеет два...

У нас есть приложение Spark Streaming (Kafka), которое также выступает в роли продюсера, создавая...

Моя схема JSON содержит типы данных со Struct, Array, Struct и Array. Когда я сам разрываю это...

Нам нужно использовать данные из определенной темы в определенное время в течение дня, мы хотим,...

Я пытаюсь создать несколько потребителей для нескольких разделов темы Kafka с одним и тем же...

У меня есть потребительское приложение kafka, где в методе слушателя аннотируется @Kafkalistener. Я...

Я разрабатываю REST API во Flask , получая данные от Кафки в режиме реального времени . Мне нужно...

У меня есть приложение весенней загрузки, которое использует kafka, но я не могу его запустить,...

Мое приложение создано с помощью SpringBoot и находится в кластере (два разных istance openshit) У...

Я хочу иметь 3 реплики kafka на 3 разных машинах. На первой машине я запускаю zookeeper со...

Я создаю Dataframe из темы kafka с использованием потокового воспроизведения.Я хочу записать...

Я пытаюсь использовать Spring Kafka с реестром схемы Confluent и Kafka Avro Deserializer. Однако в...

У нас есть следующие требования к обработке потока. Source Stream -> transform(condition check -...

Я потребляю твиты для Кафки-продюсера, а затем поглощаю их для Кафки-потребителя.Я могу заставить...

Мы работаем над распараллеливанием нашего потребителя Kafka, чтобы обработать большее количество...

Я использую пакет naf kafka-node версии 3.0.1. Однако я получаю ненужные символы в сообщении -...

Если в теме kakfa имеется более одного раздела, в java эти экземпляры / потоки потребителя будут...

В одном из приложений наш клиент получает несколько событий в файлах, загруженных на FTP-сервер....

Я должен установить IP-адрес zookeeper в ConsumerGroup вместо IP-адреса Kafka-Host. Потому что я...

У меня есть приложение, которое потребляет в качестве потока все пользовательские действия, и я...

Я пытаюсь понять kafka в некоторых деталях относительно потоков kafka (клиент потока kafka для...

Я пытаюсь использовать потребительскую библиотеку kafka, которая написана в моей организации.Он...

У меня есть кластер из 3 брокеров Kafka с коэффициентом репликации 3 для всех тем.Так как последние...

Я реализую конечную точку в весенней загрузке, которая при вызове будет делать дамп всех сообщений,...