У меня есть данные в двух темах kafka из mysql с использованием debezium-connector-mysql-plugin

Я интегрирую кафку и искру с упругим поиском. когда я запускаю этот скрипт, используя: sudo...

У меня есть сценарий использования, где мой KTable выглядит следующим образом. KTable : orderTable...

Я использую класс case, который имеет вложенные классы case, и Seq[Nested Case Classes] Проблема...

Есть ли способ передать или получить доступ к ключу сообщения из раздела join в соединении Kafka...

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

Я создаю одно приложение, в котором я получу потоковые данные (csv) из kafka и запишу их в hdfs....

У нас есть микросервисная архитектура, переданная Kafka на Confluent, где каждая служба настроена в...

Я хотел использовать confluent в среде AWS EC2.Как я могу установить его.Я попробовал confluent cli...

Есть ли способ подсчитать, сколько кучи (или любой другой) памяти приблизительно будет...

У меня есть Kafka, работающий (используя образ Docker) на одном сервере, где у меня есть Zookeeper...

У меня есть очень простое и простое приложение, в котором у меня есть тема1 и тема2, потоковое...

У меня проблема с обновлением окна в Spark Structed Streaming.Я хочу сгруппировать данные, которые...

Я делаю POC при переносе данных из Oracle db в файловую систему Hadoop с использованием Kafka...

Я пытаюсь интегрировать Apache Kafka с Elastic Stack (Beats, Logstash, Elasticsearch и Kibana) На...

У меня есть требование сделать размер пакета опроса равным 500 и выполнить пакетную фиксацию после...

Мне трудно понять пример основного потока kafka: https://github

Я пытаюсь понять внутреннюю часть потоковой передачи Spark (не структурированной потоковой...

Среда : Spark 2.4.0 Я включил банку spark-sql-kafka-0-10, и она той же версии, что и версия Spark,...

Я читал этот пост, https://nycdatascience.com/blog/student-works/yelp-recommender-part-2/, и...

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

Документация Kafka Streams 2.2.0 для метода WindowStore и ReadOnlyWindowStore fetch(K key, Instant...

Мой источник данных - Кафка, и я читаю данные из Кафки следующим образом: var df = spark

Моя цель - использовать Spark Structured Streaming для получения данных из kafka, выполнения...

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