Описание тега spring-cloud-stream-binder-kafka
Связыватель Apache Kafka для Spring-Cloud Streams.
0
ответов
Исключение тайм-аута сообщения асинхронного производителя Kafka
У нас есть приложение Springboot, которое использует spring-cloud-stream-binder-kafka для отправки сообщений в тему Kafka. Мы отправляем сообщение в синхронном режиме. Мы используем синхронный режим, потому что мы хотим выполнить некоторые действия,…
13 фев '20 в 21:16
1
ответ
Вызвано: com.fasterxml.jackson.databind.exc.InvalidDefinitionException: сериализатор не найден для класса org.springframework.core.convert.support.Defa
Я работаю над Spring Cloud Stream Apache Kafkaпример. Я разрабатываю код по ссылке: https://www.youtube.com/watch?v=YPDzcmqwCNo. org.springframework.messaging.MessageDeliveryException: failed to send Message to channel 'pvout'; nested exception is o…
18 апр '20 в 16:25
0
ответов
Как настроить тему dlq в потоке Spring Boot Kafka?
Я пытаюсь написать потребителя потока Spring boot Kafka, который может отправлять неудачные сообщения в тему dlq. Может ли кто-нибудь помочь мне примером.
01 июн '20 в 14:40
0
ответов
Spring Cloud Stream Kafka - разные настройки maxPollInterval для разных потребителей
Есть ли способ установить maxPollInterval для разных потребителей, используя Spring Cloud Stream Kafka. spring.cloud.stream.kafka.bindings.input.consumer.configuration.max.poll.interval.ms=60000 Но все же я вижу consumer.poll (polltimeout),polltimeo…
27 июн '20 в 21:08
2
ответа
Облачная функция Spring для создания GlobalKTable из потока
Есть ли пример того, как создать GlobalKTable для подсчета из KStream, используя поток Spring Cloud и используя функциональный подход?
25 мар '20 в 18:14
1
ответ
Как справиться с ошибкой сериализации в связывателе потоков Spring Cloud Stream Kafka?
Я пишу приложение потоков Kafka, используя связку потоков Kafka Stream Cloud Spring. Пока потребитель публикует сообщение в теме вывода, может возникнуть ошибка, например ошибка сериализации или сетевая ошибка. В этом коде - @Bean public Function<…
07 июн '20 в 18:16
0
ответов
Spring Cloud Stream Kafka Binder - Включение транзакций и обработка DLQ
Я разрабатываю приложение POC с SpringBoot и SpringClodStreamKafkaBinder для обмена сообщениями. Основная концепция не очень сложна. Мне нужно иметь возможность получать сообщения от кафки, а также мне нужно создавать некоторые сообщения для кафки. …
06 май '20 в 14:51
1
ответ
Есть проблемы производителя с Spring Cloud Stream 3.0
Я прочитал о документах Spring Cloud Stream 3.0, чтобы понять новое использование java.util.function.[Supplier/Function/Consumer] для представления производителей, потребления и производства, потребителей, и это должно быть правильно. Но я не понима…
02 дек '19 в 11:45
0
ответов
Spring Cloud Streams - связыватель Apache Kafka - Исключение десериализации Avro - Потребитель
Каков рекомендуемый подход для обработки исключения десериализации при использовании @StreamListener аннотация с помощью Apache Kafka Binder + Spring Cloud Streams? Я вижу документацию для Kafka Streams Binder и Spring Kafka, но не для указанной выш…
06 ноя '19 в 15:16
2
ответа
Не удалось декодировать тип json для ключа: имя_файла в потоке потока данных Spring Cloud
Я использую Spring Cloud Data Flow для настройки потока, который читает файл CSV, преобразует его с помощью специального процессора и регистрирует его: stream create --name testsourcecsv --definition "file --mode=lines --directory=D:/toto/ --file.fi…
03 дек '19 в 14:05
0
ответов
Транзакционность Spring Cloud Stream Kafka Producer в реактивном приложении Spring Webflux
Я работаю с Spring Cloud Stream Binder Kafka 3.0.0 в приложениях Spring Webflux, которые предоставляют API, который получает некоторые данные и публикует их в теме Kafka, используя @Output: @Autowired private lateinit var producer: Producer @PostMap…
11 дек '19 в 14:16
2
ответа
MessageDispatchingException: у Dispatcher нет подписчиков
Имея простую настройку Spring Cloud Stream. Интерфейс public interface MyKafkaBinding { @Output(PUBLISHER) MessageChannel publisher(); @Input("subscriber") SubscribableChannel subscriber(); } Привязка @EnableBinding(MyKafkaBinding.class) С…
04 янв '20 в 00:56
1
ответ
БД не фиксируется после потребления сообщения в Spring Cloud Stream связывателя концентратора событий Azure
У меня есть загрузочное приложение Spring для прослушивателя событий, которое выполняет операцию чтения из раздела концентратора событий Azure -> Сохранение события в БД. Я использовал Sink spring-cloud-azure-eventhubs-stream-binder(версия - 1.2.1) …
17 фев '20 в 16:38
0
ответов
@StreamListener для получения списка сообщений
Я сейчас использую @StreamListener для входящих сообщений по одному, а затем обработать его в нашем классе обслуживания, чтобы сохранить в db. Вместо этого я хочу отправлять список сообщений (скажем, 100) за раз, а затем обрабатывать его, чтобы сохр…
19 фев '20 в 08:31
2
ответа
Есть ли возможность настроить количество потоковых потоков для определенных тем, а не для всех?
В нашем приложении у нас есть несколько тем, где некоторые темы будут созданы с 16 разделами, а некоторые будут созданы с 1 разделом. Есть лиspring.cloud.stream.kafka.bindings свойство / возможность для достижения этой цели?
27 фев '20 в 13:42
0
ответов
Как справиться с противодавлением в весеннем облаке с реактивным паром
Я использую Spring Cloud для использования темы Kafka, выполнения некоторой обработки и сохранения результата в базе данных Mongo. Я заметил, что, если мой потребитель медленно обрабатывает данные, потребление памяти быстро растет, пока служба не бу…
10 мар '20 в 19:42
0
ответов
Ошибка при создании bean-компонента с именем "CompositeMessageChannelConfigurer", определенным в org.springframework.cloud.stream.config.BinderFactoryAutoConfiguration.
введите описание изображения здесь Микросервис 1: идентификатор артефакта - microservice1 Определен интерфейс KafkaStreams.java, в котором определены свойства связующего, как показано ниже. public interface KafkaStreams { String OUTPUT = "kafka-outp…
25 мар '20 в 10:39
1
ответ
при использовании @StreamListener настройка KafkaListenerContainerFactory отражается в сгенерированном KafkaMessageListenerContainer?
Я использую spring-cloud-stream со связывателем kafka для получения сообщения от kafka . Приложение в основном использует сообщения кафки и обновляет базу данных. Существуют сценарии, когда БД не работает (что может длиться несколько часов) или неко…
07 апр '20 в 15:43
1
ответ
Spring Cloud Stream Kafka Binder и Spring Cloud Azure EventHub совместимая версия для Spring Boot> 1.5.20
Я успешно использовал Spring Cloud Stream Kafka Binder (org.springframework.cloud:spring-cloud-starter-stream-kafka:3.0.1.RELEASE) и Spring Cloud Azure Event Hubs (com.microsoft.azure:spring-cloud-starter-azure-eventhubs:1.2.3) с Spring Boot 2.2.6 д…
29 апр '20 в 14:46
1
ответ
Запись в тему из процессора в приложении Spring Cloud Streams Kafka Stream
Я использую Processor API для обработки данных на низком уровне в хранилище состояний. Дело в том, что мне тоже нужно писать в тему после сохранения в магазин. Как это можно сделать в приложениях Spring Cloud Streams Kafka? @Bean fun processEvent() …
02 май '20 в 14:14