Вопросы по теме 'spring-cloud-stream-binder-kafka'
Spring Clould Stream разрешает входной канал динамически на основе сообщения
Мне нужен способ динамического разрешения входящего канала в зависимости от типа входящего сообщения. Я не ищу какое-либо решение на основе заголовков, которое уже упоминалось в этой ссылке...
77 просмотров
schedule
06.12.2023
Функция Spring Cloud и Kafka
Я изо всех сил пытаюсь понять, как мне следует тестировать приложение, которое использует Kafka Binder, а также использует функцию Spring Cloud.
Давайте воспользуемся этим очень простым примером:
@SpringBootApplication
public class...
743 просмотров
schedule
01.05.2022
Интеграция Spring Kafka MessaheChannel Thread?
У меня есть компонент потока Spring Integration (настроенный через Java DSL), который обрабатывает сообщения из канала сообщений очереди kafka, связанного с Spring CloudStream.
Источником сообщения kafka является внешнее приложение, поэтому я...
51 просмотров
schedule
16.03.2024
Программный способ чтения сообщений с помощью Spring Cloud Stream Kafka
У меня есть тема и связанный с ней DLQ. Я использую @StreamListener для этой темы. Я хотел читать / обрабатывать сообщения из DLQ по запросу с помощью конечной точки контроллера.
можно ли это сделать с помощью весеннего облачного потока Кафка....
102 просмотров
schedule
28.04.2023
Spring Cloud Stream 3.0 StreamsBuilderFactoryBeanCustomizer
Я не могу настроить пользовательские обработчики для моего потребителя потока с помощью StreamsBuilderFactoryBeanCustomizer.
@Bean
public StreamsBuilderFactoryBeanCustomizer customizer() {
return fb -> {...
121 просмотров
schedule
03.04.2023
Фактор репликации и проблема хранения Spring Cloud Stream Kafka во время выполнения
У меня есть проект весенней загрузки с использованием Kafka. Я настроил его с помощью автоматической настройки Spring Cloud Stream Kafka. Я хочу создавать свои темы автоматически с 3 репликами и сроком хранения 1 день. Для этого я добавил...
160 просмотров
schedule
04.05.2022
Почему StreamListener устарел
Я использую Spring Cloud Stream 3.1.2 вместо KafkaStreams . Модели программирования:
Функциональное программирование
Императивное программирование
Последний использует аннотации, как и все другие аннотации, которые Spring предоставляет...
681 просмотров
schedule
06.09.2022
Функция Spring Cloud StreamВывод маршрутизатора пытается привязаться к теме Kafka
Я пытаюсь перейти на новую модель функционального программирования для Spring Cloud Stream, заменив условные аннотации StreamListener, подобные этому
@StreamListener("app-input", condition = "headers['eventName']=='Funded'")...
167 просмотров
schedule
08.07.2023