У меня есть конвейер данных пакетной обработки на платформе Cloudera Hadoop - файлы обрабатываются...
Я хочу, чтобы моя служба только для подписчиков Lagom подписывалась на тему Kafka и передавала...
Уже 6 часов я перестал запускать задание Spark Streaming, которое использует тему Kafka, но я все...
Я использую Kafka с потоковой передачей Spark.Я не переопределил max.poll.records со значением по...
У меня возникла проблема при написании потока на тему из Spark. import org.apache.spark.sql.types._...
Я хочу получить данные от kafka, открываю spark-shell и, используя spark-streaming для получения...
У меня есть проблема со Spark Scala, которую я хочу умножить в элементах Tuple при потоковой...
У нас есть топология потоков, которая будет работать на нескольких машинах. Мы храним результаты...
У меня есть топология потока, определенная с помощью таблицы kafka: stream ... //irrelevant steps
Я определил конвейер, который читает тему Кафки, выполняет некоторые шаги и публикует результаты в...
мы пытаемся отойти от нашего сервера приложений J2EE классической архитектуры / реляционной базы...
Я пишу микросервисное приложение с использованием C # asp.net core 2.0, Kafka, CQRS и Confluent...
Привет, я новичок в Spark и Kafka, я пишу пример кода для использования сообщений из темы Kafka с...
У меня есть тема кафки, и каждое сообщение в теме имеет широту / долготу и метку времени события....
У меня есть потоковое потоковое приложение, которое читает данные из Kafka и записывает их в базу...
отсутствует или обнаружена неверная зависимость при загрузке файла класса 'KafkaUtils.class. Не...
В моем приложении kafka streams я использую одну тему для нескольких типов объектов, сериализуемую...
У меня проблема с широковещательной переменной при интеграции kafka и spark streaming. Если я не...
При запуске приложения Kafka stream используется следующий файл jaas. Однако билеты не обновляются...
Я пытаюсь прочитать поток из kafka, где значение представляет собой строку значений, разделенных...
Я пытаюсь сделать простой stream.leftJoin(table), но получаю следующее исключение во время...
Мое приложение Kafka streams можно запустить в Ubuntu 16.04, но когда я запускаю его в suse 11 sp4,...
Привет, я получаю эту ошибку компиляции - Unspecified Value parameters: aggregator: (String, String...
У меня есть приложение SpringBoot с двумя потоковыми процессорами, сопоставленными через Spring...
В некотором роде пост , который у меня был месяц назад.У меня есть искробезопасное приложение для...