Я пытаюсь понять разницу между joinWindows.of и joinWindows.until при выполнении левого соединения

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

У меня есть следующий код, и мне интересно, почему он генерирует только одну партию: df = spark

Я новичок в кафке.Есть ли какой-либо API для отображения результатов, такой же, как у файла...

У меня есть потоковое приложение SPARK, которое читает непрерывные входящие данные из прямого...

Чтобы создать хранилище состояний потоков Кафки в Java, я могу сделать это: final...

Я установил пакет .deb для Ubuntu 16.04 из confluent 4.1 Я могу получить штраф quickstart.Тем не...

Я использую следующие log4j.properties log4j.rootLogger=DEBUG, stdout log4j.appender.stdout=org

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

Team, Какой стратегии следует придерживаться при развертывании приложений Kafka-streams? У нас есть...

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

У меня есть Dataset<Row>, который является результатом Kafka readStream, как показано ниже в...

Нам нужно выполнить соединение Kstream - Kstream с очень большим окном, где отметка слева будет...

Я начал исследовать Spark Structured Streaming, чтобы написать несколько приложений, которые до...

У меня возникают проблемы при создании пользовательского UDAF в Ksql.Вариант использования - найти...

У меня есть работа по обогащению данных, и я обогащаю свои данные из источника данных (одна тема...

Этот вопрос касается внедрения GDPR в приложении Kafka Streams, с полной темой хранения с...

Проблема Когда я перезапускаю / завершаю / останавливаю поток, старый потребитель не умирает /...

Я передавал данные из тем Кафки с помощью Spark.Это код, который я пробовал.Здесь я просто...

STREAM-1: [KSTREAM-SOURCE-0000000000]: null, {"id": 1, "name": "john"...

Я использую kafka версии 2.11-1.0.1 и Spark версии 2.0.2.Я должен сделать dataframe для ответа...

Как определить, когда материализация KTable в теме завершена? Например, предположим, что KTable...

Я пытаюсь установить последнюю версию Confluent 4.1.x на Ubuntu 16.04.3 TLS на моем Windows 7 через...

Во всем примере я вижу простую топологию с одним преобразователем / процессором для Kafka.Я...

Мне интересно, как разделы Kafka распределяются между SimpleConsumer, запускаемым из...