Публикации по теме 'spring-cloud-stream'
Первые шаги с Spring Cloud Stream
Введение
В развивающемся ландшафте микросервисов и облачных приложений архитектура, управляемая событиями, становится популярным подходом для облегчения беспрепятственного взаимодействия между микросервисами. В экосистеме Java Spring Spring Cloud Stream — это мощная платформа, предназначенная для упрощения разработки управляемых событиями облачных приложений. Этот пост призван провести вас через ваши первые шаги с Spring Cloud Stream.
Что такое Spring Cloud Stream?
Spring Cloud..
Вопросы по теме 'spring-cloud-stream'
Облачный поток данных Spring — развертывание микросервисов
Команда, в настоящее время я работаю над spring-xd и использую его в качестве контейнера времени выполнения для анализа данных и заданий пряжи.
Мои вопросы
1) Могу ли я использовать ту же настройку среды, которую я использовал для spring-xd?...
523 просмотров
schedule
25.02.2024
Использование Spring Cloud Stream Source для отправки результатов метода в поток
Я пытаюсь создать Spring Cloud Stream Source Bean внутри Spring Boot Application, которое просто отправляет результаты метода в поток (основная тема Kafka привязана к потоку).
В большинстве примеров Stream, которые я видел, используется аннотация...
5867 просмотров
schedule
29.01.2024
Переменные `replyExpression` процессора httpclient
Я создаю конвейер с помощью стартеров весеннего облачного потока, и httpclient processor является одним из шагов. Мое требование состоит в том, чтобы вызвать удаленный http-сервер и дополнить исходное сообщение ответом. Проблема в том, что...
184 просмотров
schedule
09.05.2024
Привязать потребителя RabbitMQ с помощью Spring Cloud Stream к существующей очереди
Я создал с помощью веб-интерфейса RabbitMQ обмен темами TX и привязал к обмену две очереди TX.Q1 и TX.Q2 , каждый из них был связан с ключами маршрутизации rk1 и rk2 соответственно, и отправил на обмен несколько сообщений.
Теперь я хочу...
4637 просмотров
schedule
16.04.2024
Spring cloud stream - отправить сообщение после инициализации приложения
Я пытаюсь отправить простое сообщение, используя «весенний облачный поток» в rabbitmq. В основном код выглядит так:
@EnableBinding(Source.class)
@SpringBootApplication
public class SourceApplication {
public static void main(String[] args)...
1258 просмотров
schedule
13.03.2024
Spring Cloud Stream + Подтверждение издателя RabbitMQ
Я планирую использовать Spring Cloud Stream для своего проекта. Можно ли использовать подтверждения издателя (также известные как «Благодарности издателя»), то есть регистрировать обратный вызов подтверждения, как описано в...
1330 просмотров
schedule
10.11.2022
Как управлять подтверждением вручную с помощью Spring Cloud Stream Rabbit?
Я попробовал несколько способов управления подтверждением вручную с помощью RabbitMQ, особенно на основе этого предыдущего сообщения , но, к сожалению, ни один из них не работает.
В моем файле конфигурации я установил режим подтверждения в РУЧНОЙ...
2086 просмотров
schedule
23.09.2022
HTTP-опрос и дедупликация Spring Cloud DataFlow
Я читал много Spring Cloud DataFlow и сопутствующей документации, чтобы создать решение для приема данных, которое будет работать в развертывании Cloud Foundry моей организации. Цель состоит в том, чтобы опрашивать службу HTTP на предмет данных,...
514 просмотров
schedule
15.05.2024
Потребитель не получает сообщения после перезапуска производителя / потребителя kafka
У нас есть один производитель, один потребитель и один раздел. Оба потребителя / производителя являются приложениями с весенней загрузкой. Клиентское приложение работает на моем локальном компьютере, а продюсер вместе с kafka и zookeeper - на...
1110 просмотров
schedule
06.12.2023
Spring-stream отправляет сообщение с типом содержимого text/plain вместо application/json
Я хотел бы генерировать ответы в своей очереди с типом контента application/json, потому что полезная нагрузка содержит объект json.
Но...
Не знаю, почему мой spring-stream (на основе RabbitMQ) всегда генерирует сообщение с заголовками ниже...
1224 просмотров
schedule
07.11.2022
Весенний облачный контракт для производителя сообщений
Я использую весенний облачный контракт для сообщений, как описано в
https://cloud.spring.io/spring-cloud-static/spring-cloud-contract/1.2.1.RELEASE/single/spring-cloud-contract.html#_spring_cloud_contract_verifier_messaging
Все работает так,...
222 просмотров
schedule
26.11.2022
Сообщения Kafka обрабатываются повторно
У нас есть микросервисы, которые создают и принимают сообщения от Kafka с помощью spring-boot и spring-cloud-stream. Версии : spring -boot: 1.5.8.RELEASE Spring-cloud-stream: Ditmars.RELEASE Сервер Kafka: kafka_2.11-1.0.0
РЕДАКТИРОВАТЬ: Мы...
853 просмотров
schedule
14.10.2022
Spring Cloud Stream Kafka 2.0 - StreamListener с условием
Я пытаюсь создать потребителя, используя аннотацию StreamListener и условие attirbute, однако получаю следующее исключение:
org.springframework.core.convert.ConversionFailedException: не удалось преобразовать тип [java.lang.String] в тип...
1352 просмотров
schedule
21.01.2024
Как выполнить откат на микросервисе, когда некоторые HTTP-запросы выполнены успешно, а некоторые HTTP-запросы не выполнены с помощью jdbcTemplate
У меня есть проекты весенней загрузки, построенные на микросервисе, и я использую KONG в качестве API-шлюза. Все службы находятся в контейнере Docker .
В моей ситуации я использую цикл serviceA 20 раз, чтобы запросить удаление записей в...
495 просмотров
schedule
26.03.2024
Проблема с Spring Cloud Stream с использованием клиента реестра схемы по умолчанию вместо клиента реестра схемы Avro
Мы используем Kafka с Spring Cloud Stream, и нам нужно подключиться к Confluent Schema Registry в нашем компоненте Spring Boot, см. https://github.com/donalthurley/KafkaConsumeScsAndConfluent .
Мы добавили следующую конфигурацию для создания...
1853 просмотров
schedule
24.10.2023
Spring Cloud Stream @StreamListener и шаблон Resequencer интеграции Spring
AFAIK проект Spring Cloud Stream основан на Spring Integration. Следовательно, мне было интересно, есть ли хороший способ изменить последовательность входящих сообщений до запуска обработчика StreamListener ? Или мне нужно собрать весь...
533 просмотров
schedule
10.01.2024
Spring Cloud Streams Мульти-связыватель RabbitMQ и подключаемый модуль / приложение Shovel
Рассмотрим две системы. Каждая из систем использует выделенного брокера обмена сообщениями для связи между своими микросервисами.
Мы хотим связать эти две системы с помощью Spring Cloud Stream.
Случай А
Обе системы используют RabbitMQ в...
233 просмотров
schedule
06.12.2022
Spring Cloud Stream: @StreamListener дважды обрабатывает сообщения
Я использую Spring Cloud Stream (Edgware.SR5) с Spring Boot (1.5.10.RELEASE). Мой @StreamListener дважды обрабатывает каждое полученное сообщение.
Идея примера - опубликовать сообщение в очереди и обработать его.
Услуга:...
3071 просмотров
schedule
14.11.2023
папка для кроликов весна-облако-ручей неразделенное место назначения
Я использую spring-cloud-stream: 2.1.1.RELEASE со связывателем Rabbit.
Имена очередей, сгенерированные для моей привязки, всегда имеют расширение -0, например:
test-data-direct.group01-0
test-data-direct - это имя обмена, а group01 - это имя...
26 просмотров
schedule
14.04.2024
Исключения времени выполнения приложения не отправляются в errorChannel или ServiceActivator, которые не могут прослушивать errorChannel
После прослушивания темы kafka с помощью @StreamListener, при RuntimeException глобальный канал erroChannel или канал errorChannel для конкретной темы (topic.group.errors) не получает сообщения об ошибке. @ServiceActivator ничего не получает....
367 просмотров
schedule
12.03.2024
