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

Попытка запустить azure-sample , но при поступлении запроса возникает ошибка «Не удалось найти основной класс». Создайте проект в eclipse с помощью maven. Обновленный код на основе этой проблемы (иначе вы получите исключение ClassCast)....

У меня есть библиотека на основе Spring Boot (с использованием spring-data-mongo), которая создает PersistentEntities bean. PersistentEntities реализует интерфейс Supplier<T> , поэтому функциональный связыватель Spring Cloud Stream создает...

Я пытаюсь использовать Spring Cloud Kafka Streams для обработки сообщений из темы Kafka, содержащей различные типы сообщений. Например, мы получаем сообщение JSON из темы, которое может быть сообщением типа A или типа B. Производитель добавляет тип...

Я использую связыватель кролика весеннего облачного потока с функцией весеннего облака и определяю таких слушателей, как: public Function<Flux<SomeObject>, Flux<OtherObject>> foo() { //some code } Я также перенаправляю...

Я использую облачную функцию Spring для обработки данных из kafka с помощью Flux. По умолчанию он обрабатывает данные в потоке потребителя (где используется сообщение). Я собираюсь реализовать пул потоков для параллельной обработки и регулирования...

Данный: cloud: stream: rabbit: bindings: inboundApolloLookupVehicleChannel: destination: fed.apollo-vehicle-lookup-test group: apollo-mngt-group consumer: missingQueuesFatal:...

Мне очень нравится, как облачная функция Spring отделяет бизнес-логику от цели среды выполнения (локальной или облачной) и упрощает интеграцию с бессерверными поставщиками. Я планирую использовать SCF с AWS Lambda за шлюзом API для проектирования...

Я пытаюсь написать реактивную службу Spring Cloud Function с использованием RabbitMQ, которая будет потреблять одну очередь и производить обмен. У меня 2 вопроса. Почему я получаю ошибку ниже в логах. Как мне отклонить запрос с doOnError?...

Я пытаюсь создать реактивное приложение Spring Cloud Stream с kafka, следуя функциональному подходу (Spring Boot: 2.3.4, SC: Hoxton.SR9, SC Stream: 3.0.9, SC Function 3.0.11). Проблема: автоматически десериализованный объект имеет пустые значения...

Я создал простую облачную функцию Google с библиотекой Spring Cloud Function, которая запускается по прибытии сообщения Pub / Sub. Я следил за образцом function-sample-gcp-background . Каждый раз, когда сообщение отправляется в Pub / Sub, оно...