Вопросы по теме 'spring-cloud-stream'
шаблон обмена сообщениями запрос-ответ Spring-Cloud-Stream
Есть ли шаблон запрос-ответ, который следует использовать с Spring-Cloud-Stream? Вся документация, которую я могу найти на spring-cloud-stream, ориентирована на тип производителя MessageChannel.send, и я знаком с @MessagingGateway из...
2619 просмотров
schedule
29.11.2022
Преобразование JSON сообщения Spring Cloud Stream не работает
Я выполнил свой предыдущий вопрос Сообщение Spring Cloud Stream из / в преобразование JSON конфигурация и настроенный поток, как описано, но я не могу заставить его работать правильно.
Моя установка выглядит следующим образом. У меня есть два...
4893 просмотров
schedule
12.05.2022
Разделение. Всегда ли количество экземпляров потребителей должно соответствовать количеству разделов, предоставленному производителем?
В моем приложении Producer.properties у меня есть
spring.cloud.stream.bindings.output.producer.partitionKeyExpression=payload
spring.cloud.stream.bindings.output.producer.partitionCount=4
И мой потребительский application.properties выглядит...
886 просмотров
schedule
19.07.2023
Слушатели динамических приемников Spring Cloud Stream
Я начинаю использовать SCS, и у меня есть следующий вариант использования:
Пользователь открывает сеанс HTTP
Сервер динамически определяет, для какого раздела создать прослушиватель приемника, на основе атрибутов безопасности пользователя....
656 просмотров
schedule
13.07.2023
Настраиваемое название темы приложения Spring Cloud Stream
Я пытаюсь найти способ настроить тему, которую будет слушать весенний облачный поток @StreamListener. Моя первая попытка заключалась в том, чтобы попытаться использовать SPeL, чтобы получить это, например.
@StreamListener("#{...
1057 просмотров
schedule
27.02.2022
Безопасно ли использовать локальный сервер Spring Cloud Dataflow в рабочей среде?
Мы изучаем возможность реализации весеннего облачного потока данных в локальной системной среде для обработки потоков и задач для повседневных транзакций. Не используя PCF, Kubernetes, YARN или Mesos, мы подумываем об использовании локального сервера...
689 просмотров
schedule
17.05.2023
весна-облако-поток-кафка не уважает одного потребителя для группы
Я использую spring-cloud-stream-kafka . Я запускаю 2 экземпляра потребительского приложения с одним и тем же именем группы testGroup , потребляющих сообщения из темы Kafka testTopic с одним разделом, я ожидал, что один из экземпляров-потребителей...
410 просмотров
schedule
30.07.2023
Источник данных Redis для весеннего облачного сервера потока данных
Согласно документации, служба Spring Cloud Dataflow использовала СУБД для хранения определений потоков/задач, регистрации приложений и репозиториев заданий. Вместо использования RDBMS есть ли способ использовать Redis для хранения этой информации.
465 просмотров
schedule
22.05.2023
Потребительские шаблоны Spring Cloud Stream Kafka
Для темы с несколькими разделами -
1) Использует ли один экземпляр SpringBoot несколько потоков для обработки (метод, аннотированный StreamListener) каждого сообщения из каждого раздела?
2) Можно ли настроить более одного потока для каждого...
1707 просмотров
schedule
21.02.2024
Как отправлять сообщения на два разных канала вывода в SCDF?
У меня есть источник, который отправляет сообщения по каналу output по умолчанию процессору в потоке. Теперь я хочу также отправлять сообщения об ошибках по другому каналу.
Я решил, что мне нужно создать привязываемый интерфейс, который...
1409 просмотров
schedule
31.05.2022
Весенний облачный поток с привязкой кафки
Я новичок в весеннем облаке, и я ищу любой простой полный пример для весеннего облачного потока с использованием брокера kafka.
240 просмотров
schedule
19.11.2022
Отсутствует класс AvroSchemaMessageConverter в схеме spring-cloud-stream-1.2.0.RC1
Мне не хватает класса AvroSchemaMessageConverter в схеме spring-cloud-stream-1.2.0.RC1. Я хочу по этой ссылке отсутствует модуль схемы для spring-cloud-stream .
<dependency>
<groupId>org.springframework.cloud</groupId>...
1213 просмотров
schedule
15.07.2022
Spring Stream пытается создать тему вместо очереди в IBM MQueue
Я пытаюсь понять, как использовать Spring Boot Streams с MQueue, используя spring-cloud-stream-binder-ibm-mq . Я могу подключиться к MQueue, но получаю Could not provision topic 'queue///EMB_DEV_QUEUE' и MQJE001: Completion Code '2', Reason...
1049 просмотров
schedule
02.06.2023
@PostConstruct и автоматическое подключение MessageChannel
У меня проблема с Spring Cloud Stream. Дело в том, что у меня есть bean-компонент, который будет писать в Kafka, как только он будет создан (метод, аннотированный @PostConstruct), поэтому я автоматически подключаю соответствующий MessageChannel и...
437 просмотров
schedule
14.11.2022
Подтверждение доставки кролика Spring Cloud Stream
Как обеспечить гарантированную доставку в Spring Cloud Stream Rabbit. Мой код ниже: -
class Source {
MessageChannel output;
Repository repo;
@Transactional
void publisher(Command command){
repo.save(command);...
470 просмотров
schedule
12.05.2023
Обработка исключений с помощью Spring Cloud Stream и RabbitMq
У меня проблема с поиском информации об обработке исключений в Spring Cloud Stream. Я знаю, что есть errorChannel , который должен обрабатывать исключения, но я понятия не имею, как его использовать. Может ли кто-нибудь дать мне образцы? В...
889 просмотров
schedule
04.06.2022
spring-cloud-stream-kafka Потреблять только последние сообщения после запуска приложения
В нашем проекте мы используем spring-cloud-stream-binder-kafka версии 1.1.2 для интеграции с kafka. Недавно у нас была ситуация, когда одна из наших служб потребляла старые сообщения (уже использованные) из темы после запуска. В этой теме есть 2...
704 просмотров
schedule
19.11.2022
Spring Kafka - Источник событий - Пример того, как запросить состояние некоторой сущности с помощью Kafka + KafkaStreams API
Я использую Kafka для реализации архитектуры, основанной на поиске событий.
Допустим, я храню события в формате JSON:
{"name": "ProductAdded", "productId":"1", quantity=3, dateAdded="2017-04-04" }
Я хотел бы реализовать запрос, чтобы...
3947 просмотров
schedule
01.06.2022
Конфигурация протокола безопасности spring-cloud-stream не применяется
Я пытаюсь настроить протокол безопасности связывателя Kafka. Как описано в справочнике spring-cloud-stream, свойство security.protocol должно существовать в иерархии spring.cloud.stream.kafka.binder.configuration, но эта конфигурация не применяется....
700 просмотров
schedule
07.05.2023
Как пропустить строку заголовка (первую строку) файла в springcloudstream с помощью DSL?
Я использую облачный поток Spring для чтения файла и разделения с помощью разделителя файлов и выделения каждой строки в виде сообщения с использованием стиля DSL, файл, который я читаю, имеет строку заголовка, просто интересно, есть ли простой способ...
382 просмотров
schedule
29.04.2023
