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

Я оцениваю требование переместить тестовые данные из локальной настройки kafka в kafka в облаке...

Название темы: testTopic Всего сообщений в теме: 1 Раздел: 8 Название группы потребителей:...

Потребитель Alpakka kafka обрабатывает записи до тех пор, пока не обнаружит запись, которую он не...

У меня 1 зоопарк, 1 ансамбль Кафки.Я использую пакет kafka-node npm для подключения к брокеру Kafka...

Я настраивал значение для параметра fetch.max.bytes, и я получил исключение, что максимальное...

Мне интересно, есть ли что-то, чего мне не хватает в моей настройке, чтобы облегчить длительные...

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

Внезапно у меня возникла проблема с запуском группы потребителей apache kafka. Кто-нибудь,...

Привет, похоже, я не могу правильно масштабировать мой модуль для потокового приложения Kafka...

Используя плагины Telegraf, есть способ прочитать данные из InfluxDb и опубликовать их в теме Kafka

Я пытаюсь выяснить, как обработать исключение с ошибочным сообщением Avro.В настоящее время я...

Я получаю файлы данных от Kafka в формате XML или AVRO. Каждое сообщение заключено в двойные...

У меня есть две коллекции, пользователи и транзакции на mongodb, я отправил их в kafka и теперь мне...

Я делаю тесты с Кафкой и Голангом Я использую: Docker: https://hub.docker.com/r/bitnami/kafka...

У меня есть темы в Кафке, которые хранятся в формате Avro. Я хотел бы использовать всю тему...

У меня есть служба Windows, написанная на C #.Ранее мы использовали концентраторы событий с...

Используя образ kafka-lenses-dev , я столкнулся с проблемами при подключении Kafka к локальному...

Я пытаюсь настроить продюсера для отправки сообщений, используя node-rdkafka, в службу потока...

Я использую docker-kafka проекта wurstmeister для запуска kafka / zookeeper в контейнере.Я создаю...

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

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

Мне недавно задали вопрос об устройстве системы в интервью: Предположим, что приложение позволяет...

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

Я пытаюсь написать отдельную Java-программу, использующую API-интерфейс kafka-jdbc-connect для...