Описание тега spring-boot-cloud-streams
0
ответов
Как отключить все автоконфигурации, связанные с Kafka, из файла yaml/properties в spring-boot-2 без удаления зависимостей?
У меня есть проект gradle spring-boot-2, также в build.gradle Файл, который я добавил, Kafka связанных зависимостей, которые приведены ниже. dependencies { implementation 'org.springframework.cloud:spring-cloud-starter-zipkin' compile 'org.springfra…
20 авг '19 в 11:40
1
ответ
Путаница в реализации KStream / Table в Spring Boot
Я пытаюсь получить образец работающего "действия" в Spring-Boot kafka stream, и я, кажется, в итоге запутался:) Я получаю данные JSON по проводам. Я построил схему в avro, которую я использую для сериализации данных: { "UID": "XJ3_112", "type": "11X…
20 июн '19 в 13:43
0
ответов
Невозможно сгенерировать правильную схему Avro и схему Confluent с использованием потока Spring Boot Cloud
Я извлекаю данные из темы кафки, используя Avro и Confluent Registry. Я хочу привести эти данные к пользовательскому типу и записать их в другую тему, также используя реестр Avro и Confluent. Отражение используется, но регистрируемая схема содержит …
15 июл '19 в 11:39
0
ответов
Как настроить тему dlq в потоке Spring Boot Kafka?
Я пытаюсь написать потребителя потока Spring boot Kafka, который может отправлять неудачные сообщения в тему dlq. Может ли кто-нибудь помочь мне примером.
01 июн '20 в 14:40
1
ответ
Вызвано: java.lang.ClassNotFoundException: org.springframework.integration.dsl.IntegrationFlowBuilder
Я работаю на Spring Cloud Stream using RabbitMQ с помощью Spring Boot v2.2.6.RELEASE. Ошибка: java.lang.IllegalStateException: Error processing condition on org.springframework.cloud.stream.config.BindingServiceConfiguration at org.springframework.b…
17 апр '20 в 21:39
0
ответов
Cloud Stream - слушайте список тем без жесткого кодирования или настройки
Я хочу прочитать в облачном потоке список тем (входящие). Идея состоит в том, чтобы сканировать сообщения всех тем, чтобы сохранить 1 из 10000 сообщений для статистики. После запуска моего приложения можно создавать новые темы. Я могу прочитать спис…
10 окт '19 в 10:43
0
ответов
Springboot Cloud Stream Kafka Binder - как обрабатывать исключение DLQ и исключение десериализации?
1) Для потребителя Springboot Cloud Stream Kafka Binder после x повторных попыток сообщение об ошибке отправляется в DLQ. Мой вопрос: если запись в сам DLQ имеет исключение, как мы обычно обрабатываем это исключение? Есть ли у нас механизм для повто…
08 окт '19 в 23:25
1
ответ
num.stream.threads создает простаивающие потоки
У меня есть приложение Spring boot kafka stream с 2 темами, рассмотрим темы A и B. В теме A есть 16 разделов, а в теме B - 1 раздел. Считайте, что приложение развернуто в 1 экземпляре, имеющем num.stream.threads=16. Я выполнил команду kafka-consumer…
27 фев '20 в 14:06
1
ответ
Как подключить функциональные компоненты Spring Cloud Stream к Binder Kafka?
Я использую документацию Spring Cloud Streams, чтобы попытаться понять, как подключить мой микросервис к Kafka через связующее, уже загруженное в Gradle. Я пробовал создать простой@Bean Function<String, String>() в моем классе Spring Boot Appl…
25 мар '20 в 01:22
0
ответов
Spring boot amazon kinesis consumer автоматически вставляет таблицу в DynamoDb
Я не хочу использовать Dynamodb для хранения полезной нагрузки. Есть ли другой способ избежать этого, потому что по умолчанию он создает таблицу в Dynamodb и вставляет. @EnableBinding(Sink.class) @SpringBootApplication public class KinesisConsumerAp…
08 июн '20 в 21:06
0
ответов
springbootmicroservices- Ошибка обработки запроса; вложенное исключение - java.lang.IllegalStateException: URI запроса не содержит допустимого имени хоста:
org.springframework.web.util.NestedServletException: Request processing failed; nested exception is java.lang.IllegalStateException: Request URI does not contain a valid hostname: at org.springframework.web.servlet.FrameworkServlet.processRequest(F…
18 июн '21 в 22:14
0
ответов
Can I use "spring-cloud-stream-binder-kafka", "spring-cloud-stream-binder-kafka-streams" and "spring-cloud-stream-binder-rabbit" in SpringBoot?
I'm learning Spring Cloud Streams and managed to create a multi-binder Spring Boot project that combines both Kafka and Rabbit: <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-stream-binder-…
15 ноя '21 в 07:20
1
ответ
Тема Kafka и тема реестра схемы
У меня есть вопрос о настройке потокового процессора с Kafka и разными именами темы (брокер Kafka) и темы (Schema Registry). spring: cloud: schema-registry-client: endpoint: http://localhost:8081 cached: true stream: function: definition: process de…
15 ноя '21 в 19:25
0
ответов
Настройка топологии потоков Kafka с помощью функции Spring bean
Я пытаюсь запустить среду тестирования топологии Kafka. Производственный код действительно небольшой @SpringBootApplication public class ProcessApplication { public static void main(String[] args) { SpringApplication.run(ProcessApplication.class, ar…
18 ноя '21 в 13:52
0
ответов
Отправка сообщения в тему Kafka и регистрация обратного вызова
Я отправляю сообщение в тему Kafka, используя streamBridge. В качестве побочного эффекта успешной отправки мне необходимо выполнить обновление базы данных. У StreamBridge нет никаких обратных вызовов, которые я могу присоединить, и он вызывается аси…
16 мар '22 в 17:13