Я собираюсь создать потоковое приложение Kafka на основе Java, которое будет непрерывно слушать...
Я собираюсь рассчитать среднее с потоками кафки.Поэтому я делаю операцию с состоянием, агрегат,...
Я хочу создать приложение Kafka Streams, которое получает сообщения типа A.Для каждого ввода A...
Давайте рассмотрим две системы.Каждая из систем использует выделенный брокер обмена сообщениями для...
Я пытаюсь создать приложение Flask, в котором в качестве интерфейса используется Kafka.Я...
Я создаю сервис, использующий Apache Beam (поток данных), который считывает данные из kafka,...
Я пытаюсь использовать KSQL (как часть confluent-5.0.0) для создания одной записи из набора...
Я пытаюсь установить MQTT-коннектор для Kafka Connect, работающего в Docker.Я видел, как это...
Хочу подтолкнуть данные к кафке с искровой работы. Я использую потоковую передачу Spark Kafka...
Я столкнулся с некоторой проблемой в моей собственной настройке Kafka (слияния). Найдите...
Когда мне нужно загрузить тему без ключа как kTable, я обычно использую тему как kStream,...
Я запускаю этот кусок кода.StreamingInputDF - это readStream по теме Kafka.Я использую spark 2.4.0...
Я работаю над созданием приложения с помощью IBM MQ.Предлагаемая архитектура для его построения...
Я пытаюсь запустить очень простой пример.У меня есть Кафка readStream, которая читает из темы Кафки
Я использую Spark Structured Streaming для чтения из темы Kafka. Без какого-либо раздела...
В базовой конфигурации Kafka .NET, например, такой: conf = new ConsumerConfig { GroupId =...
У меня есть файл журнала темы и соответствующий файл .index.Я хотел бы читать сообщения в потоковом...
Например, потребление электроэнергии на одного клиента.Данные о потреблении не транслируются...
Это обобщение этого вопроса . Предположим, у меня есть несколько исходных потоков, для которых...
После пакета Spark ETL мне нужно записать в тему Kafka результирующий DataFrame, содержащий...
Я создаю материализованное представление из темы с помощью функции агрегирования из API весеннего...
Каков реактивный способ реализовать бесконечный цикл опроса с использованием Reactor?В идеале я...
Я хочу прочитать данные из темы и группы kafka по ключевым значениям и записать в текстовые файлы .
Я пытаюсь перенести журнал из темы в другую тему.Мне нужно подключить Кафку к Кафке с помощью Flume
У меня проблема с разработкой эффективного конвейера Spark для варианта использования ETL.Это...