Я хочу читать и писать, используя структурированную потоковую передачу в Confluent Cloud. Проблема...

например. У меня есть тема «тест» с 4 разделами. Когда я запускаю потоковое приложение, и через...

Я пытаюсь подключить кафку остальных прокси к сливному облаку. kafka-rest-start ccloud-kafka-rest

Я использую kafkaUtils.createDirectStream () в потоковой передаче искры. Этот метод поможет мне...

Я пытаюсь реализовать поток Kafka, который обрабатывает сообщения о посещении веб-сайта...

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

Я настраиваю приложение Kafka Streams, которое использует тему (срок хранения: 14 дней, cleanup

У меня проблемы с преобразованием моих данных в правильный поток байтов в искровой фрейм данных с...

Я хочу записать данные структурной потоковой передачи в Cassandra с помощью PySpark API...

Я использую искру для записи данных в kafka таким способом. df.write (). Формат ( "Кафка"). save ()...

Я получаю сообщение об ошибке "Исключение в потоке" main "java.lang.NoSuchMethodError: org.apache

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

я использую версию spark-sql-2.4.1 с Kafka 0.10 v. Пока я пытаюсь использовать данные потребителем....

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

У меня странная проблема, которую я не могу понять, как я могу решить. У меня есть приложение kafka...

Ссылка на: https://spark.apache.org/docs/2.2.0/streaming-kafka-0-10-integration

Я строю топологию потоков kafka, в которой мне нужно материализовать содержимое Global KTable в...

Мы используем Kafka Streaming для нашей долгосрочной задачи потоковой передачи. Заданная нами...

У меня есть один сервер Zookeeper (скажем, xx.xx.xx.xxx:2181), работающий на одной виртуальной...

Я новичок в kafkaStream, я разрабатываю Stream, но когда я запускаю свое приложение, в журналах...

Можно ли выполнить обработку потока kafka от определенного смещения входной темы до конечного...

У меня проблема с KSQL: потеря данных во время потока обновлений (завершение потока запросов и...

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

Я хочу объединить журналы по идентификатору в пределах окна времени, используя Kafka Streams. На...

Я упрощаю свою проблему по следующему сценарию: 3 друга делят карту лояльности. Карта имеет два...