Так что в основном у меня есть класс Account.У меня есть данные.Я хочу отправить эти объекты в мою...

При запуске My spark Kafka Direct Stream будут использоваться только те сообщения, которые были...

У меня есть удаленный сервер kafka с 3 узлами и 1 узлом zookeeper. Также у меня есть кластер с...

Я получаю CSV в теме Кафки «raw-data», цель состоит в том, чтобы преобразовать их, отправив каждую...

У меня вопрос по поводу интеграции alpakka_kafka+alpakka_s3.Alpakka s3 multipartUpload не загружает...

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

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

У меня установлены разъемы источника и приемника с использованием слияния, и они работают нормально

История вопроса В настоящее время мы используем: API-интерфейс Kafka Streams (версия 1.1.0) для...

Я использую следующую конфигурацию docker-compose: app-zookeeper: image: wurstmeister/zookeeper...

Я хотел бы понять следующее: В структурированной потоковой передаче Spark существует понятие...

Итак, вопрос заключается в безопасности использования внешнего хранилища состояний внутри потоковых...

Я пытаюсь создать bean-компонент kstreams и автоматически связать его с моим сервисом. Но даже если...

У меня vagrant box с приведенными ниже конфигурациями Ubuntu. $ lsb_release -a No LSB modules are...

Не могли бы вы дать мне знать, как обрабатывать нулевое значение в KSQL. Я пытался обработать 4...

В моих приложениях Spring Boot я использовал Kafka и Spark , где Spark считывает поток из Kafka,...

Мы обновились с Confluent 4.0.0 до 5.0.0, после обновления мы не можем перечислить задержку...

Могу ли я использовать процессор api в Kafka Streams и считывать данные из темы в одном кластере...

При каких обстоятельствах программа Kafka Streams должна сериализоваться / десериализироваться

Я использую Stream Streaming (2.1) для отправки некоторых данных в kafka (некоторые версии 0.10,...

При использовании сообщений с использованием библиотеки Confluent Kafka C # я хочу видеть новое...

Я хочу создать rdd из python-kafka в моем потоковом приложении. Мой код: from pyspark import...

Мы работаем над приложением Spark Streaming, в котором оно получает данные из kafka. У нас есть...

Я пишу приложение для библиотеки книг, и у меня есть 2 микросервиса: memberService и bookService

Я экспериментирую с запуском структурированной потоковой передачи из источника kafka и возвращаю их...