Здесь мой KSQL, используя WINDOW TUMBLING предложение: SELECT sale_date, region, SUM(total) FROM...
Когда я пишу приложение, используя Processor API, и если я использую addSink для передачи журналов...
Попытка записи данных в тему Kafka с использованием Spark Structured Streaming и получение...
Есть ли в Kafka процедура для резервного копирования данных брокера Kafka? Как работает резервное...
В документации говорится: state.dir Каталог состояний.Kafka Streams сохраняет локальные состояния в...
Я использовал для установки автономного Confluent Сервер со встроенным Zookeeper (ZK).Но теперь мой...
Я получаю неравномерный размер тем Кафки.Мы хотим перераспределить входной RDD на основе некоторой...
Я пытаюсь прочитать тему Kafka из кластера Spark с использованием API-интерфейса структурированной...
У меня есть два потока приложений kafka. Я могу видеть там группы потребителей, используя:...
В нашем приложении мы используем структурированную потоковую передачу с MapGroupWithState в...
Я новичок в Kafka иasticSearch, я хочу перенести данные Elasticsearch в тему kafka, с соединителем...
Мне было поручено разрушить среду разработки и заново настроить ее с нуля, чтобы проверить наши...
Когда метод process вызывается при переопределении класса процессора низкого уровня (например,...
моя версия для потокового воспроизведения - 2.0, версия для kafka - 0.10.0.1,...
Скажем, у вас есть тема с нулевым ключом, значение которой равно {id:1, name:Chris, age:99}...
Ниже приведен пример кода, в котором мы пытаемся удалить дубликаты на основе некоторого значения...
Моя цель - извлечь данные из Kafka с помощью Spark Streaming, преобразовать данные и сохранить их в...
Я немного новичок в Scala и Spark, поэтому не стесняйтесь судить меня, но не слишком сложно. Я...
Я использую Kafka Stream для своей темы A, и я использую в MemoryKeyValueStore. builder
Это вопрос новичка к кафке-стримингу. Как бы вы собрали пары сообщений, используя библиотеку java...
Я пытаюсь использовать logstash-output-kafka в logstash: Файл конфигурации Logstash input { stdin...
В моем сценарии у меня есть несколько наборов данных, которые приходят время от времени, и которые...
Какая разница между этими сущностями? Как мне кажется, KTable - простая тема кафки с compaction...
У нас есть проблема с удалением каталога состояний в потоковом приложении Kafka.Мы работаем с...
Пожалуйста, найдите нижеприведенную проблему и подтвердите ее. Шаг-01: На основе условия соединения...