Я использую производителя kafka и потребителя Spring kafka. Я использую сериализатор и...

при вводе данных в Producer - Kafka - Logiste - Elastic Search. В это время, если Kafka накапливает...

Я создал потоковую программу для потокового оплога mongodb, используя flink и kafka. Согласно...

Я создал минимальное приложение jhipster с генератором 5.0.1 с kafka 1 : 3 коммита Генерация...

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

У нас есть темы со сроком хранения 7 дней (168 часов).Сообщения потребляются в режиме реального...

Я хочу перенаправить строковую переменную в cmd изнутри os.system() в python Я получаю следующую...

Мне нужно направить сообщения ActiveMQ на Кафку (Cloudera), используя Camel с использованием...

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

Я сталкиваюсь с ошибкой ниже, когда пытаюсь вставить сообщение в Kafka через API производителя org

Я использую Apache Kafka в качестве контейнера Docker https://hub.docker.com/r/wurstmeister/kafka/...

Я прочитал отсюда и немного не уверен насчет журнала разделов. Сначала они говорят: Для каждой темы...

Я набираю "confluent start schema-registry", и он загружает zookeeper, kafka и завершается с...

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

Apache Pulsar (от Yahoo), похоже, является следующим поколением Apache Kafka. Apache RocketMQ (от...

Версии: GoLang 1.10.2 Kafka 4.4.1 Docker 18.03.1 Я пытаюсь использовать пакет Sarama от Shopify,...

у нас есть кластер HDP версии 2.6.4 с 3-мя серверами zookeeper версии 3.4.x первый сервер zookeeper...

Привет, есть ли у кого-нибудь пример вызова в Kafka REST Proxy для отправки сообщения в тему, а...

Я пытаюсь настроить идентификацию kerberos между zookeeper и kafka. Я выполнил следующие шаги...

Проблема: у меня есть таблица во внешней базе данных, содержащая события kafka, которые я опросил с...

Я публикую сообщение на topicX.Чтобы использовать это сообщение несколькими потребителями, я...

У меня есть группа потребителей с несколькими потребителями.Каждому потребителю назначается набор...

Я использую Spring kafka listener для чтения сообщений из темы kafka. @KafkaListener( id =...

Я использую этот учебник для настройки проекта.Все работает хорошо, пока я не добавлю фабрику...

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