Вопросы по теме 'spring-cloud-stream'
Разница между кодеком и MessageConverter при интеграции Spring
Были представлены кодеки в Spring интеграции 4.2.
Однако описание в документах на самом деле не описывает, чем кодек отличается от _ 1_ или в каких сценариях какую абстракцию использовать?
В основном я хочу знать:
Почему была...
560 просмотров
schedule
01.03.2023
Как использовать @RefreshScope с классами, аннотированными @EnableBinding?
@EnableBinding превращает класс в @Configuration , и задокументировано следующее:
@RefreshScope работает (технически) с классом @Configuration, но это может привести к неожиданному поведению: например. это не означает, что все @Beans,...
1220 просмотров
schedule
13.06.2023
Некоторые проблемы при запуске spring-cloud-stream-samples
Я запускаю приложение https://github.com/spring-cloud/spring-cloud-stream-samples/tree/master/stream-listener , встретил некоторые ошибки, почему?
Sending value: hi of type class demo.domain.Foo
2016-04-07 19:19:50.811 ERROR 76016 ---...
432 просмотров
schedule
24.05.2022
идентификаторы, назначенные базой данных для обмена сообщениями микросервисов
Компания, в которой я работаю, изучает возможность перехода от нашего текущего монолитного API к микросервисам. Наш текущий API сильно зависит от Spring, и мы используем SQL-сервер для большей устойчивости. Наше исследование микросервисов склоняется...
249 просмотров
schedule
05.02.2024
Spring Cloud Stream DataFlow - не удается загрузить класс драйвера: com.mysql.jdbc.Driver
Я просто тестирую пример этого URL HTTP в MySQL , где целью является создание потока из http в базу данных MySQL.
Согласно примеру, вся информация о соединении jdbc указана в определении потока (jdbc --includes = 'mysql: mysql-connector-java:...
1084 просмотров
schedule
23.11.2022
Как перехватить сообщения Spring Cloud Stream?
Spring позволяет перехватывать сообщения для многих своих продуктов, таких как RestTemplate и SpringMVC. Можно ли перехватить сообщения Spring Cloud Stream? Как для входящих, так и для исходящих сообщений.
4804 просмотров
schedule
14.10.2023
Ручное подтверждение сообщений: Spring Cloud Stream Kafka
Сценарий, который я хочу реализовать, - это принять сообщение от Kafka, обработать его, если какое-то условие не выполняется, я не хочу подтверждать сообщение. Для этого я нашел в справочной документации Spring Cloud Stream,
autoCommitOffset...
4884 просмотров
schedule
17.07.2023
как отправлять и получать из одной и той же темы в spring cloud stream и kafka
У меня есть приложение spring-cloud-stream с привязкой kafka. Я хотел бы отправить и получить сообщение из одной и той же темы из одного и того же исполняемого файла (jar). У меня есть определения каналов, как показано ниже: -
public interface...
3576 просмотров
schedule
24.07.2023
Сжатие связующего материала Spring Cloud Stream Kafka
Как включить сжатие (например, GZIP) для производителей, использующих Spring Cloud Stream Kafka Binder?
1216 просмотров
schedule
06.03.2023
Источник Kafka в потоке данных Spring Cloud
Я перехожу с Spring XD на Spring Cloud Data Flow. Когда я искал список модулей, я понял, что некоторые из источников не указаны в Spring Cloud Flow - один из них - источник KAFKA.
У меня вопрос: почему источник KAFKA удален из списка стандартных...
2511 просмотров
schedule
11.04.2022
Как создать процессор с транзакцией и DLQ с привязкой Rabbit?
Я только начинаю изучать Spring Cloud Streams и Dataflow и хочу узнать об одном из важных для меня вариантов использования. Я создал пример процессора Multiplier, который принимает сообщение и повторно отправляет его 5 раз на вывод....
1332 просмотров
schedule
07.02.2023
Поддерживает ли Spring Cloud Stream RabbitMQ Stomp через Websocket
Я использую Spring Cloud Stream (SpringBoot) для связи с экземпляром RabbitMQ .
Проект может подключаться к RabbitMQ через AMQP , но не работает для STOMP . Кто знает: stomp поддерживается или нет и как настроить? (Мой RabbitMQ открыл порт...
313 просмотров
schedule
24.09.2023
Spring Cloud Stream не создает очередь
Я пытаюсь настроить простое приложение Spring Cloud Stream с RabbitMQ. Код, который я использую, в основном взят из spring-cloud-stream-samples . У меня есть точка входа:
@SpringBootApplication
public class DemoApplication {
public static...
3657 просмотров
schedule
04.10.2023
Spring Cloud Stream Kafka ›получение сообщений Avro из прокси-сервера Confluent REST
У меня такой сценарий:
Производитель отправляет сообщения в кодировке Avro в тему Kafka через прокси-сервер Confluent REST (который регистрирует схему в реестре схем Confluent), как описано в...
2890 просмотров
schedule
16.06.2023
Путаница в компонентах Spring Cloud
Как эти компоненты Spring соотносятся / отличаются друг от друга? Что каждая из них представляет концептуально? Можно ли использовать их вместе или это конкурирующие проекты?
Поток данных Spring Cloud
Весенний поток облаков
Весенняя...
330 просмотров
schedule
18.07.2023
Потребитель Spring Cloud Stream kafka, который привязан к нескольким темам
Я хочу настроить одно потребительское приложение (будет работать на одной JVM), которое будет привязано к нескольким темам. Каждый метод «потребления» (скажем, у меня есть 2 темы для прослушивания) в потребительском приложении будет установлен с...
1549 просмотров
schedule
20.11.2022
Модульный тест для агрегированного приложения весеннего облачного потока
Я после модульного теста для агрегированного приложения весеннего облачного потока, основной метод выглядит следующим образом:
@SpringBootApplication
public class MyApplication {
public static void main(String[] args) {
new...
320 просмотров
schedule
25.12.2022
Обмен разветвления Spring Cloud Stream Rabbit MQ
В своем приложении я интегрирую Rabbit MQ с помощью весеннего облачного потока. По умолчанию весенние облачные потоки создают пункт назначения как тему обмена в Rabbit MQ. Как настроить Spring Cloud Stream для создания обмена типа fanout?
1417 просмотров
schedule
09.07.2023
Перехватить входящее сообщение Spring Cloud Stream SubscribableChannel
Поскольку метод postReceive из org.springframework.messaging.support.ChannelInterceptor не вызывается в org.springframework.messaging.SubscribableChannel . Есть ли способ перехватить все входящие сообщения для метода annotated...
2309 просмотров
schedule
07.07.2022
Динамические каналы Spring Cloud Stream
Я использую Spring Cloud Stream и хочу программно создавать и связывать каналы. В моем случае при запуске приложения я получаю динамический список тем Kafka, на которые можно подписаться. Как я могу создать канал для каждой темы?
6419 просмотров
schedule
31.08.2022
