Каковы рекомендуемые настройки для сквозной передачи с низкой задержкой от публикации производителя...

Последняя версия kafka поддерживает семантику "точно один раз" (EoS).Чтобы поддержать это понятие,...

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

Я установил offset.store.method для брокера на потребителе, однако он не работает в сценарии ниже....

Требуется для генерации метрик задержки потребителя для нашего приложения (Kafka 0.10), в котором...

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

У меня возникла проблема при попытке подключиться к экземпляру Kafka, который использует...

Я скачал kafka_2.12-2.1.0 и поместил в путь к папке "C: \ kafka_2.12-2.1.0".Для запуска kafka...

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

У меня есть сценарий, в котором входные данные процесса находятся в HashMap с именем атрибута в...

Я создаю службу аутентификации с помощью Django для архитектуры микроуслуг.это скорее эксперимент,...

Я запускаю образ док-станции kafka.Я наблюдаю за отключениями потребителей по тому же конкретному...

Привет! Я создал поток со следующими значениями из темы: "id VARCHAR, src_ip VARCHAR, message...

У нас есть диспетчер, который получает сообщение, а затем «распределяет» его по нескольким...

Mosca выдает эту ошибку: TypeError: Client is not a constructor at new KafkaAscoltatore...

В настоящее время у меня есть кластер подключения Kafka с двумя узлами, использующими одинаковые...

У меня возникла следующая проблема: я работаю над потоковым приложением, которое использует Kafka и...

Я использую Spring KafKa, и я устанавливаю ackMode в MANUAL_IMMEDIATE props

Я хочу настроить прием kafka druid, но даже после настройки в common.runtime.properties и...

Я настраиваю Кафку в своем местном.Я распаковал версию 2.12 и запустил zookeeper.Zookeeper запущен...

В настоящее время я пишу веб-приложение, в котором есть множество микросервисов.В настоящее время я...

Хотел бы, чтобы потребитель подписывался на все темы I * Новые темы, начинающиеся с I, могут быть...

Как найти смещение сообщения в теме Кафки?Содержит ли смещение несколько сообщений или одно...

У меня есть система, которая сохраняет координаты (X, Y) в таблицу SQL.Затем у меня есть конечная...

Я попытался создать базу данных с двумя таблицами в sqlite.Однажды в моей таблице есть столбец...