Простой вопрос, я всегда читал об использовании Kafka с потоковой передачей искры...

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

Я пытаюсь перевести реализацию Spark в Pyspark, которая обсуждается в этом блоге: https://dorianbg

Если по какой-то причине нам необходимо отключить кластер kafka и с помощью искровой потоковой...

Я использую структурированную потоковую обработку Spark (используйте SSS в качестве сокращения...

Я пытаюсь написать потребителя Kafka (из protobuf), используя структурированную потоковую передачу

Допустим, у меня есть topicA, topicB и topicC, обе темы разделены по отдельным типам событий на...

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

Я пытаюсь настроить работу Spark на использование данных от Kafka.У брокеров Kafka настроен SSL, но...

Допустим, мы собираем статистику совместимости моделей автомобилей и шин.Входной поток перечисляет...

Я устанавливал kafka в Quickstart Cloudera VM, используя следующую ссылку , но когда я запускаю...

Рассмотрим этот цикл событий: В то время как больше сообщений msg_in = consumer.Poll () msg_out =...

У меня есть тема Zeromq, которая генерирует сообщения каждую секунду. Пример: {Orderno : 123 ,...

У меня есть приложение kafka, настроенное на использование реестра схемы.V1 приложения была...

В нашем проекте мы рассматриваем возможность использования kakfa с потоковой передачей Spark, для...

У меня есть файлы AVRO, отсортированные по ID, и у каждого ID есть папка с именем «ID = 234», а...

Я пытаюсь получить список тем, присутствующих на сервере kafka, используя пакет kafka-node....

в моем приложении Spring Cloud Spring (с Kafka) я хотел бы написать KStream<SomeKey,...

Учитывая DataStreamReader, настроенный для подписки на несколько тем, подобных этой (см. здесь ):...

У меня есть статический Dataframe (CSV-файл) и тема KAFKA (скажем, Topic1) в качестве входных...

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

Я хочу получить только первое сообщение от производителя Kafka, и на основе этого сообщения я...

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

Чтобы сравнить производительность приложения Spring Cloud Stream (с Kafka), использующего RocksDB...

Я не смог найти документацию, рассказывающую, как использовать spark-streaming-kafka-0-10_2.10 с...