Я начинающий с Кафкой.Я использую Kafka Consumer в моей автоматизации, я могу получать сообщения,...
У меня Zookeeper и Kafka, работающие на физическом сервере, и я собрал докер-контейнер, на котором...
У меня сейчас проблема с кодом, который я написал для Кафки.Код довольно прост, источник производит...
Я уже некоторое время изучаю Apache Kafka. Давайте рассмотрим следующий пример. Предположим, у меня...
Я хочу использовать потребление Kafka в Nifi, чтобы использовать тему.Исходя из этого, я хочу взять...
У меня есть очередь kafka, работающая и получающая сообщения.Я связал Nifi с этой темой (о kafka),...
Я запустил процесс Nifi (Consume Kafka) и подключил его к теме.Он работает, но я не могу (не знаю),...
Я пытаюсь понять, что хранит схема-реестр для каждой схемы.Куда мне обратиться или какой инструмент...
Использование Kafka Broker: 1.0.1 spring-kafka: 2.1.6. ВЫПУСК Я использую пакетный потребитель со...
Я использую Ubuntu 18 и использую Java (intellij IDE) и пишу базовое приложение для kafka. Я...
Я использую Java сервлет. В файле web.xml я инициализировал кварцевый планировщик. У меня есть 2...
Я использую следующую раковину.Проблема в том, что он устанавливает имя индексаasticsearch так же,...
Можно ли прочитать одно сообщение из компактной темы Kafka, если я знаю ключ сообщения? Я не нашел...
Я пытаюсь читать темы Кафки через Apache Spark Streaming и не могу понять, как преобразовать данные...
Я не хочу фиксировать смещения для тех сообщений, обработка которых не удалась, и я хочу, чтобы они...
У нас есть 3 узла кластера и 7 брокеров. Теперь мы должны создать тему и создать разделы для этой...
Я играл с базовой настройкой Zookeeper и Kafka, чтобы узнать, как ее использовать, но у меня...
Я использую API-интерфейс Kafka Consumer для копирования всех данных из раздела Kafka в таблицу...
Я пишу приложение Kafka Consumer на основе Java. Я использую kafka-клиенты, Spring Kafka и Spring...
У меня есть тема кафки, которая получает сообщение. Теперь мой потребитель получает объект с...
Производитель Kafka отправляет файлы .gz, но не может распаковать и прочитать файлы на стороне...
Я получаю данные JSON из файла в мой файл JavaScript. Теперь я хочу отправить эти данные из этого...
Я использую клиент Kafka Java, и иногда у нас бывает время простоя на Kafka Server. Нам нужно...
Я работал над кодированием потоков Кафки. Попытка сначала создать несколько примеров для понимания....
Или, может быть, даже способ задержать сообщение, полученное потребителем. Мне нужно делать вызов...