Описание тега spring-cloud-dataflow

Spring Cloud Data Flow - это набор инструментов для построения конвейеров интеграции данных и обработки данных в реальном времени. Конвейеры состоят из приложений Spring Boot, созданных с использованием микросервисных фреймворков Spring Cloud Stream или Spring Cloud Task. Это делает Spring Cloud Data Flow подходящим для ряда сценариев использования обработки данных, от импорта / экспорта до потоковой передачи событий и прогнозной аналитики.
1 ответ

Пример тикстока Spring Cloud Dataflow не выполняется в CloudFoundry

Я пытаюсь получить самый простой пример для Spring Cloud Dataflow, работающего на CloudFoundry. Я выполнил следующие действия: http://docs.spring.io/spring-cloud-dataflow-admin-cloudfoundry/docs/current-SNAPSHOT/reference/htmlsingle/ чтобы сделать п…
1 ответ

Нет основного атрибута манифеста при выполнении компонента streams spring-cloud-starter-stream

Я импортировал банку вручную из моего репо м2: app register --name file --type source --uri file://<LOCAL_PAT>/spring-cloud-starter-stream-source-file-1.3.1.RELEASE.jar при запуске определения потока я всегда получал в логах эту ошибку: нет ос…
19 июн '18 в 15:20
1 ответ

Запуск нескольких SCDF(локальный сервер не на основе CF), указывающий на одну БД для HA

Мы используем SCDF 1.2.3.RELEASE (локальный сервер) для вызова другой задачи, созданной с помощью весенней облачной задачи 1.2.2.RELEASE. Мы хотим запустить несколько экземпляров SCDF в нашей среде, чтобы обеспечить высокую доступность и (распределе…
08 фев '18 в 12:53
1 ответ

Совокупные сообщения в Spring Cloud Stream

Я новичок в Spring Cloud и хочу изменить нашу моноструктуру на микро-сервисы. Сначала я сказал, что я пытаюсь сделать следующее: Получать запросы на вызов веб-службы (внешней системы) из разных источников. В любое определенное время это может быть 1…
1 ответ

Поток данных весеннего облака исчерпывает место на диске

У нас есть большое количество задач (~30), запущенных SCDF на PCF, однако мы сталкиваемся с проблемами дискового пространства с SCDF, проблема, по-видимому, связана с загрузкой артефактов SCDF при каждом вызове задачи. Артефакты в нашем случае загру…
0 ответов

Приложение для обработки асинхронных запросов Http в Spring Cloud Dataflow

Я создаю поток в Spring Cloud Dataflow, в котором приложение Source отправляет идентификатор приложению Processor. Этот процессор должен использовать этот идентификатор в асинхронном HTTP-запросе и переслать ответ приложению Sink. Под асинхронным ht…
29 апр '18 в 10:46
1 ответ

Настройка Spring Batch Администраторский интерфейс консоли с Springboot

Я работаю над переносом существующего весеннего приложения на весеннюю загрузку. Приложение имеет весенние периодические задания. Хотелось бы узнать конфигурацию для настройки весеннего пакетного интерфейса консоли с пружинной загрузкой. Существующи…
1 ответ

Ошибка сборки при обновлении spring-cloud-starter-dataflow-server-local до 1.3.0

Ранее я использовал Spring-Cloud-Starter-Dataflow-Server-Local 1.2.3.RELEASE, и он работал отлично. Когда я обновляюсь до 1.3.0.RELEASE, сборка не удалась с ошибкой компиляции: org.springframework.beans.factory.BeanCreationException: Error creati ng…
1 ответ

Переопределение свойств в определении потока Spring Cloud Dataflow

Для потоков Kafka (потребителей), которые используют KafkaAvroDeserializer, мне нужно переопределить некоторые настройки при развертывании с помощью --propertiesFile для работы. KafkaBinder 1.1.1 добавил эту опцию конфигурации. Я предпочитаю не испо…
31 янв '17 в 00:14
1 ответ

Удаление встроенного заголовка в динамически генерируемых местах назначения

Я хотел отключить встроенный заголовок в сообщении при использовании динамически сгенерированного места назначения, как в примере, приведенном здесь (скажем, output themes = dyntopic1,dyntopic2,...). Я установил свойства, как показано ниже, но я все…
1 ответ

Spring Cloud Data Flow Server несколько пространств имен

Мне нужна помощь в развертывании весеннего облачного сервера потоков данных. Я хочу развернуть приложение с помощью helm и развернуть потоки в разных пространствах имен. Несмотря на то, что я обновляю карту конфигурации Skipper с несколькими учетным…
2 ответа

Как настроить gemfire как хранилище сообщений для модуля агрегатора в потоке данных весеннего облака

Ссылка - https://github.com/spring-cloud-stream-app-starters/aggregator/tree/master/spring-cloud-starter-stream-processor-aggregator не перечисляет свойства для хранилища сообщений gemfire
11 фев '19 в 10:54
1 ответ

Преобразование сообщений AvroSchema в приложении Spring Cloud Dataflow Sink

Я пытаюсь использовать Преобразование сообщений на основе схемы Avro в приложении Spring Cloud Stream, которое является приемником. Из ошибок не могу понять, зачем нужен дополнительный канал, потребитель 'redis-sink:0.input'. Я развернул его с помощ…
2 ответа

Пользовательский интерфейс Spring Cloud Dataflow не отображает свойства из белого списка

У меня Spring Cloud DataFlow v1.3.1.RELEASE, работающий локально, и я создал небольшое примерное "процессорное" приложение, чтобы проиллюстрировать происходящее. Приложение Boot имеет два класса @ConfigurationProperties: DemoApplicationProperties: @…
23 мар '18 в 19:21
1 ответ

Вопросы о составленном процессоре и приемнике

Я использую Spring Could Data Flow 1.7.2.RELEASE и пытаюсь подписаться на этот пост создать "комбинацию процессор + приемник в одном приложении:" новый приемник "". Когда я структурировал свой код в качестве примера блога, у меня возникли проблемы, …
11 янв '19 в 19:23
1 ответ

Управление потоками данных Spring Cloud с помощью SSL

Невозможно получить доступ к конечной точке управления после того, как локальный весенний облачный сервер потока данных включен ssl и имеет базовую аутентификацию У меня есть файл docker-compose.yml, который может запустить сервер потока данных с ss…
25 янв '19 в 01:04
2 ответа

Невозможно развернуть / запустить задачи на Pivotal CF из-за ошибки контейнера Spring Cloud Dataflow CF-UnprocessableEntity(10008)

Попытка развернуть приложение / задачу Java Spring Boot с использованием Spring Cloud Data Flow. Но это терпит неудачу за следующим исключением CF-UnprocessableEntity(10008): семантически недопустимый запрос: у задачи должна быть капля. Укажите капл…
1 ответ

Невозможно создать составную задачу с помощью DSL, когда включена регистрация

У меня есть эта конфигурация безопасности: security: basic: enabled: true realm: Whatever user: name: some-name password: super-secret role: VIEW, CREATE, MANAGE Когда я пытаюсь создать новую составную задачу, вставляя код в представление DSL, я пол…
05 дек '17 в 12:44
2 ответа

Весенний облачный поток данных Httpclient

У меня есть следующий поток.Контекст проблемы 1. rabbit --password='******' --queues=springdataflow-q --virtual-host=springdataflow --host=172.24.172.184 --username=springdataflow | transform | httpclient --url-expression='http://172.20.24.47:8080/p…
1 ответ

Получение DataFlowClientException в весеннем облачном потоке данных

Когда я пытаюсь дать приведенную ниже команду в оболочке, я получаю следующую ошибку. Пожалуйста, дайте мне знать, почему я получаю эту ошибку. Я пытаюсь выполнить приведенную ниже ссылку Maven Репозиторий локальный: C: \ maven https://www.javainuse…