Следуя совету здесь , я пытаюсь использовать встроенный Kafka для тестирования моего приложения...
У меня есть проект начальной загрузки, который имеет зависимости spring-cloud-starter-stream-kafka...
Я бы хотел использовать Spring Cloud Stream Kafka для своей службы Java / Spring, и мне нужно...
Я реализую Kafka listerner (Consumer) с загрузкой Spring, событие приходит к методу, который должен...
Я использую сообщения в пакетном режиме. Я хотел извлечь 8 сообщений каждые 250 мс из потока....
Spring Kafka и, следовательно, Spring Cloud Stream , позволяют нам создавать транзакционных...
У меня есть приложение, которое прослушивает разные источники событий. Для каждого из этих событий...
Я использую Spring Cloud Finchley.RELEASE с RocksDb и Kafka-Streams для производственного...
Мы используем Spring Cloud для обслуживания асинхронных задач. Интересно, есть ли способ...
Мое приложение использует один поток, а затем отправляет сообщения в три потока Связующее: public...
Можно ли использовать одну и ту же привязку для создания сообщений через Kafka Producer и для...
Я занимаюсь разработкой приложения (на основе микросервисов), опираясь на Kafka и Kafka Streams. Я...
Я ищу способ связать обмен RabbitMQ с другим через весенний облачный поток.Я знаю, что могу...
У меня есть простой источник и приемник RabbitMQ.Я публикую сообщение в исходной очереди со...
Spring Cloud Stream и кафка. Эта ошибка появляется после добавления следующих зависимостей. (Если я...
Я использую Spring Integration + Spring Cloud Stream для создания следующего потока: @Bean public...
У меня есть xml <?xml version = ....... <A>1</A> <B>2</> </> Я...
При использовании шины springcloud пользовательское сообщение создается и отправляется через...
В приложении № 1 я создаю KTable - KTable<Windowed<String>, GenericRecord> table =...
Я отправляю 100 сообщений в поток с 1 шрадом. spring: cloud: stream: bindings: myOutBound:...
Наше приложение должно читать из Kafka и использовать шаблон Scatter-Gather / Aggregate для...
Я пытался реализовать балансировку нагрузки для потребителей потока Aws kinesis В соответствии с...
Я пишу загрузочное приложение Spring, которое будет использовать две разные темы и обрабатывать...
Я пытаюсь интегрировать весенний облачный поток с функцией весеннего облака. Webflux поскольку в...
У нас есть три контейнера, которые подключаются к потоку Kinesis как потребители, использующие...