Вопросы по теме 'spring-cloud-stream'
цикл зависимости от весеннего перехватчика WebSocket и весеннего облачного потока
Я пытаюсь создать перехватчик веб-сокетов, который отправляет сообщение с помощью MessageChannel из весеннего облачного потока. я сталкиваюсь с циклом зависимости
┌─────┐
| myChannelInterceptor defined in file...
676 просмотров
schedule
10.09.2022
Как заставить процессор httpclient Spring Cloud Stream App Starter отправлять сообщения об ошибках из ответа API в приемник журналов?
Когда я проверяю журналы stdout для моего процессора httpclient, я вижу, что получаю ответ 422, когда делаю запросы. Фактическое сообщение об ошибке, отправленное с ответом, потеряно, или, по крайней мере, я не уверен, как к нему добраться. Можно ли...
97 просмотров
schedule
09.01.2024
Источник файла начального приложения Spring Cloud Stream для Spring Batch Cloud Task
У меня есть приложение для весенней пакетной загрузки, которое принимает в качестве входных данных плоский файл. Я преобразовал приложение в облачную задачу и развернул весной локальный сервер потока данных. Затем я создал поток, начиная с File...
429 просмотров
schedule
09.11.2022
Сбросить смещение темы, создав новую группу потребителей при каждом перезапуске приложения.
У меня есть тема Kafka и потребитель с назначенной группой потребителей (обязательно) в приложении Spring Cloud. Как требование, при каждом перезапуске приложения мне нужно начать читать все полученные сообщения с самого начала. Это должно было быть...
658 просмотров
schedule
01.05.2024
Тема Spring Cloud Stream для каждого сообщения для разных потребителей
Я ищу топологию
До сих пор я не видел способа определить тему для каждого сообщения в Cloud Stream. Я понимаю, что потребители будут привязаны к определенной теме, но как производитель устанавливает тему для каждого сообщения перед...
1257 просмотров
schedule
03.11.2022
Обработка ошибок в Spring Cloud Stream - Kafka Binder
Я пытаюсь реализовать функцию обработки ошибок для SCS с помощью Kafka Binder, и в настоящее время у меня возникают проблемы с добавлением ошибок в тему ошибок.
1) Есть ли что-то конкретное, что должно быть указано для ошибок в файле .yml,...
3201 просмотров
schedule
02.01.2024
Spring Cloud Contract и два сервиса, которые одновременно являются производителями и потребителями.
TL; DR: как сгенерировать заглушки для двух сервисов, которые обмениваются информацией (следовательно, оба являются производителями и потребителями)?
Hi,
Я разрабатываю приложение, использующее архитектуру микросервисов с maven, Spring Boot,...
285 просмотров
schedule
21.01.2024
Исключение при запуске потребителя - (невозможно назначить одно и то же имя группы для разных каналов в микросервисе)
Я новичок в Spring Cloud Stream и rabbitmq. Недавно я получил исключение после запуска одного из моих микросервисов. В нем говорится, что не удалось зарегистрировать объект, потому что он уже зарегистрирован, я думаю, это из-за имени группы,...
1859 просмотров
schedule
19.04.2024
MessageConversionException при попытке сериализовать список Avro SpecificRecords и разделить их с помощью @Splitter
У меня есть сплиттер Spring Cloud Stream (Elmhurst Release) со связующим RabbitMQ. Я пытаюсь обновить его, чтобы он использовал схему Avro для полезных данных. Я получаю исключение преобразования, из-за которого создается впечатление, что...
1639 просмотров
schedule
13.12.2023
Кафка отмечает координатора мертвым, когда включено автомасштабирование
Мы запускаем кластер Kubernetes с Kafka 0.10.2. В кластере у нас есть набор реплик из 10 реплик, запускающих одну из наших служб, которые используют одну тему как одну группу потребителей.
Недавно мы включили функцию автомасштабирования для этого...
289 просмотров
schedule
28.01.2024
Как прослушивать несколько тем с помощью нескольких StreamListener Spring Cloud Stream и Kafka Stream
Я хочу послушать две темы Kafka, как в приведенном ниже коде, и есть два исходных события, которые необходимо обработать и преобразовать в другое событие.
Итак, я хочу послушать эти два события в одном EnableBinding...
1807 просмотров
schedule
22.02.2024
Как использовать интерактивный запрос в топологии процесса kafka в Spring-Cloud-Stream?
Можно ли использовать интерактивный запрос (InteractiveQueryService) в Spring Cloud Stream в классе с аннотацией @EnableBinding или внутри метода с @StreamListener? Я попытался создать экземпляр ReadOnlyKeyValueStore в предоставленном...
924 просмотров
schedule
18.10.2023
Spring-Cloud-Stream обрабатывает сообщения kafka только после того, как хранилища состояний, материализованные при запуске приложения, были полностью заполнены и готовы
Ссылаясь на это решение , мой файл spring-cloud-stream application.yml имеет следующую конфигурацию:
#application.yml
spring.cloud.stream.bindings.input:
destination: my-topic-name
contentType: application/json
consumer:...
923 просмотров
schedule
07.10.2023
Spring Cloud Stream и Kafka: ошибка сериализации Kafka Producer
Я новичок в Spring Cloud Stream и Kafka. Я получаю следующую ошибку от производителя kafka при отправке строки в полезной нагрузке. Любая помощь или идеи приветствуются. Я пробовал использовать сериализатор / десериализатор bytearray, а также json...
3396 просмотров
schedule
07.11.2022
Создание агрегатора Kafka и присоединение к нему с событием
Я пытаюсь создать агрегатор, в котором я прослушиваю несколько записей и объединяю их в одну. После консолидации я жду события процесса, присоединяя поток и агрегированное приложение в методе listen(). При поступлении события процесса запускается...
208 просмотров
schedule
20.08.2022
Сокращение шаблона в приложении Spring Cloud Kafka Streams
В моем приложении Spring Cloud Kafka Streams я хочу присоединить KTable<String, Foo> к KTable<String, Bar> . Входные данные для моего приложения были закодированы с использованием MessagePack, поэтому я определил Serdes для Foo и...
57 просмотров
schedule
14.04.2024
Как использовать Kafka-события с функцией spring-cloud, но только иногда производить
Я успешно настроил spring-cloud-function с kafka-streams в Kotlin и имею рабочий прототип.
У меня есть одна функция, которая получает события из одной темы и создает другое событие для другой темы.
Вот мой application.yml
spring:
cloud:...
514 просмотров
schedule
20.12.2023
