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

Ниже приведен код потребителя для получения и обработки сообщений из раздела kafka (8 разделов)....

Я использую openjdk: 8-alpine для развертывания приложения Kafka Streams.Я использую Windowing, и...

Я пытаюсь выполнить в реальном времени ввод данных Kafka в HBase через PySpark в соответствии с...

Я знаю, что можно настроить фактор репликации для этих внутренних тем для потоков kafka, наше...

Я хочу получать сообщения от моего брокера Kafka с помощью настроенного потребителя весенней...

Я не смог найти здесь и на веб-сайте и в блогах Spring, если Spring Cloud Stream может предоставить...

Я пытаюсь развернуть докерский кластер kafka с 3 узлами zookeeper и 3 kafka.Узлы kafka продолжают...

Я учу кафку с помощью Confluent Platform.Я следовал их краткому руководству по началу работы с...

У меня есть запрос ksql, который объединяет два потока, выполняет оконную агрегацию,...

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

Я смотрю на сервис весенней загрузки, который читает сообщения от apache kafka, запрашивает записи,...

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

Мне нужно настроить кластер Kafka на разных машинах, но он не работает, когда я запускаю...

Я использую данные из темы кафки через структурированную потоковую передачу, в теме 3 раздела

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

Я использую Spark Structured Streaming для классического варианта использования: я хочу прочитать...

Я пытаюсь понять дельту блоков данных и думаю сделать POC, используя Кафку.По сути, планируется...

Мы работаем с Spark 2.4.0 / Scala 2.11 и запускаем несколько потоковых приложений Spark, слушающих...

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

У меня есть следующий фрагмент кода для ежечасной агрегации данных на основе времени события...

Существует топология: .mapValues((key, messages) -> remoteService.sendMessages(messages))

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

Я получаю множество следующих журналов предупреждений zookeeper: 2019-02-25 08: 50: 17,599] INFO...

Я пытаюсь настроить поступление данных Кафки в реальном времени в HBase через PySpark в...