Я настраиваю новое потоковое приложение Kafka и хочу использовать пользовательское хранилище...

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

Я запускаю скрипт с помощью этой команды spark-submit --packages org.apache

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

Я пытаюсь понять обходной путь, который упоминается в: https://issues.apache

Я использую Confluent Platform 4.1.1 для передачи данных с sql-сервера в базу данных Oracle.Для...

Как интегрировать кафку с колбой? Я сделал это, но при отправке сообщения возникла ошибка...

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

Деталь: Мы Dockerized Kafka, Cassandra и Spark, используя wurstmeister/kafka, strapdata/elassandra...

у нас есть кластер Kafka с тремя узлами. У нас странная проблема. Когда контроллер становится...

Я должен сосчитать различные события во временном интервале.У меня есть события, связанные с...

У нас есть следующие требования к обработке потока. Source Stream -> transform(condition check -...

Я читаю данные из раздела Kafka и помещаю их в Azure ADLS (как в HDFS) в режиме секционирования....

Я пытаюсь создать потоковое приложение Spark, которое читает из Kafka. Я смотрел на руководство...

Я новичок в потоковой передаче kafka-spark и пытаюсь реализовать примеры из документации spark с...

Мой текущий проект работает в пакетном режиме, т. Е. Выполняется ежедневно ночью. Когда мои...

У меня есть 2 потоковых запроса, как показано ниже val streamingQuery = injectableDependencies

Я хотел вывести безопасную схему из данных JSON, полученных от Кафки. df = spark.readStream

Мой вариант использования - получить последнее значение для любой ключ в теме Кафки.Для этого я в...

проблема использование Spring Kafka версия: org.springframework.kafka: spring-kafka: 2.0.0.RELEASE....

Я изменил свою версию akka-stream-kafka с 0.11-M2 до 0.17, для этого также потребовалось, чтобы...

Я использую PostGre в качестве базы данных.Я хочу захватить одну таблицу данных для каждого пакета...

Я переключаю приложение с потоковой передачи на структурированную. Это приложение для чтения логов...

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

Я пишу приложение Kafka Streams.Он выполняет следующие шаги: «1) использует входные данные 2)...