Описание тега spring-cloud-stream
Spring Cloud Stream позволяет пользователю разрабатывать и запускать микросервисы обмена сообщениями с помощью Spring Integration и запускать их локально, в облаке или даже в Spring Cloud Data Flow. Просто добавьте @EnableBinding и запустите свое приложение как приложение Spring Boot (контекст одного приложения). Вам просто нужно подключиться к физическому брокеру для шины, что происходит автоматически, если соответствующая реализация шины доступна в пути к классам.
1
ответ
Пример тикстока Spring Cloud Dataflow не выполняется в CloudFoundry
Я пытаюсь получить самый простой пример для Spring Cloud Dataflow, работающего на CloudFoundry. Я выполнил следующие действия: http://docs.spring.io/spring-cloud-dataflow-admin-cloudfoundry/docs/current-SNAPSHOT/reference/htmlsingle/ чтобы сделать п…
03 мар '16 в 15:32
1
ответ
Совокупные сообщения в Spring Cloud Stream
Я новичок в Spring Cloud и хочу изменить нашу моноструктуру на микро-сервисы. Сначала я сказал, что я пытаюсь сделать следующее: Получать запросы на вызов веб-службы (внешней системы) из разных источников. В любое определенное время это может быть 1…
24 ноя '16 в 05:58
2
ответа
Весенний облачный поток kafka 2.0 - StreamListener с условием
Я пытаюсь создать потребителя, используя аннотацию StreamListener и условие attirbute. Однако я получаю следующее исключение: org.springframework.core.convert.ConversionFailedException: не удалось преобразовать тип [java.lang.String] в тип [java.lan…
26 июл '18 в 14:53
1
ответ
Идемпотентный приемник - есть ли эквивалент FilteringMessageListenerAdapter/RecordFilterStrategy для StreamListener
Мне нужно реализовать идемпотентный слушатель, используя весенний облачный поток kafka binder. Как можно обернуть StreamListener, чтобы можно было применить необходимые рекомендации по фильтрации / дедупликации, прежде чем сообщения будут делегирова…
26 ноя '18 в 17:24
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…
21 фев '18 в 21:05
1
ответ
Spring Cloud Stream 2.0 и последний запуск startOffset
При обновлении нашего приложения до весенней загрузки 2.0.3 мы столкнулись с проблемой потребления сообщений и использования startOffset: latest,Сценарий, который мы протестировали, выглядит следующим образом: развернуть приложение с потребителем (t…
25 ноя '18 в 13:23
1
ответ
Определение потребительского тега для RabbitMQ с использованием Spring Cloud Stream
Можно ли определить потребительский тег для привязки rabbitmq с помощью весеннего облачного потока? Например, я связываюсь с rabbitmq и вижу следующее для моего потребительского тега в консоли администратора: amq.ctag-qeGdyc32v1BS4LkYHi39aw. Я не ви…
13 сен '18 в 21:14
1
ответ
Объединение адаптеров входящего канала и передатчика потока
Я играю с реактивным весенним облачным потоком и сталкиваюсь с проблемой. Рассмотрим следующий код: @InboundChannelAdapter("list", poller = [(Poller(fixedDelay = "\${thetis.listInterval:60000}"))]) fun timerMessageSource(): Flux<Center> = conf…
16 мар '18 в 12:24
1
ответ
Удаление встроенного заголовка в динамически генерируемых местах назначения
Я хотел отключить встроенный заголовок в сообщении при использовании динамически сгенерированного места назначения, как в примере, приведенном здесь (скажем, output themes = dyntopic1,dyntopic2,...). Я установил свойства, как показано ниже, но я все…
31 янв '18 в 13:16
0
ответов
Spring Cloud Streams Multi-Binder RabbitMQ против плагина / приложения Shovel
Давайте рассмотрим две системы. Каждая из систем использует выделенного брокера обмена сообщениями для связи между своими микро-сервисами. Мы хотим связать эти две системы, используя Spring Cloud Stream. Случай А Обе системы используют RabbitMQ в ка…
27 ноя '18 в 10:08
1
ответ
СКС Кафка, потребитель обрабатывает только последние сообщения
Я использую SCS 1.3.0.RELEASE. У меня есть производитель и потребитель приложений. Не запуская потребительское приложение, я использовал приложение-производитель для отправки нескольких сообщений. Затем запустил потребительское приложение, но сообще…
26 окт '17 в 16:25
1
ответ
Преобразование сообщений AvroSchema в приложении Spring Cloud Dataflow Sink
Я пытаюсь использовать Преобразование сообщений на основе схемы Avro в приложении Spring Cloud Stream, которое является приемником. Из ошибок не могу понять, зачем нужен дополнительный канал, потребитель 'redis-sink:0.input'. Я развернул его с помощ…
21 май '18 в 08:59
1
ответ
Как добавить условие SpEL для дат в @StreamListener
Я могу отправлять сообщения через Kafka или RabbitMQ и использовать их с помощью @StreamListener. Я хотел бы сейчас пропустить сообщения, для которых один заголовок не соответствует условиям даты. Например, я бы ожидал что-то вроде этого: @StreamLis…
01 фев '19 в 22:54
1
ответ
Удалить логи кафки для использованных сообщений, используя SCS
Новичок в использовании кафки и весеннего облачного потока. Нужна помощь. Настроить У меня есть два подпружиненных приложения App-1, App-2. Я использую Spring Cloud Stream и Spring-Cloud-Stream-Binder-Kafka для асинхронной связи. Есть одна тема ТЕМА…
16 июн '18 в 08:28
1
ответ
Получение DataFlowClientException в весеннем облачном потоке данных
Когда я пытаюсь дать приведенную ниже команду в оболочке, я получаю следующую ошибку. Пожалуйста, дайте мне знать, почему я получаю эту ошибку. Я пытаюсь выполнить приведенную ниже ссылку Maven Репозиторий локальный: C: \ maven https://www.javainuse…
03 фев '19 в 06:42
1
ответ
Весенний облачный поток: две разные кафки в одном приложении
Я пытаюсь использовать две разные Кафки в одном приложении. Когда у меня есть только одна Кафка, мой application.yml: spring: cloud: stream: kafka: binder: brokers: kafka_broker01 zkNodes: kafka_broker01 headers: type binders: some-binder: type: kaf…
20 фев '19 в 18:17
2
ответа
Как использовать RMQ и весенний облачный поток для создания потребителя на основе разделов
Я могу разработать образец потребителя, используя облачный поток и rabbit mq, если у меня есть 3 раздела, созданные производителем, и если я разверну 3 экземпляра в CF, каждый выбирает одну очередь и обрабатывает сообщения с использованием индекса, …
27 апр '17 в 14:46
1
ответ
spring-cloud-stream kafka, как создать сообщение с круговой стратегией?
Мы обновили весеннюю загрузку до версии 2.0.3 (ранее 1.5.10). В связи с этим мы изменили релиз kafka & spring-cloud-stream (2.0.0-Release) В нашем файле свойств YML мы не всегда настраиваем partitionKeyExpression и большинство наших partitionCount б…
18 ноя '18 в 11:44
1
ответ
Spring Cloud Stream Elmhrust.RELEASE не может изменить Serde
Я не могу изменить Serde канала (или привязку), используя синтаксис, указанный в документации ( https://docs.spring.io/spring-cloud-stream/docs/Elmhurst.RELEASE/reference/htmlsingle/). Предполагая, что мой канал pcin, Я понимаю, что я должен указать…
18 апр '18 в 23:24
0
ответов
Спецификация канала Spring Cloud Stream для потребителя / производителя
Я пытаюсь установить свойства в Conusmer/Producer с Kafka Stream/@StreamListener Kstream, но не могу заставить его работать; spring.cloud.stream.kafka.streams.bindings.channel.consumer|producer.**configuration**.x Свойства, которые меня больше всего…
21 фев '19 в 14:59