С помощью приложения Spring Cloud Stream Kafka, как мы можем гарантировать, что потоковый...

Virtualhost не создается на сервере RabbitMQ в зависимости от конфигурации Должен ли я убедиться,...

Я пытаюсь отправлять и получать сообщения по каналам / темам, чьи имена назначения находятся в базе...

Я пытаюсь создать Потребитель kafka с Spring Cloud Stream для прослушивания сообщения Kafka,...

Я использую SCDF [Spring Cloud Data Flow], и в своем потоке я агрегирую полезные нагрузки, а в...

Я новичок в весенней интеграции Kafka и весеннем облачном потоке данных.поэтому моя проблема...

Согласно документам здесь поддерживаемые в настоящее время связующие ( Rabbit и Kafka ) полагаются...

Я использую версию весенней загрузки 2.0.3-RELEASE.Это мой конфигурационный файл.Когда я запускаю...

Мой потребитель привязан к анонимной группе потребителей вместо указанной мной группы потребителей....

Я решил пойти с SCS, чтобы не застрять с конкретным брокером сообщений.Сказав это, я не нашел...

Мы используем приложения потока потоков данных весеннего облака и RabbitMQ в качестве посредника...

Версии: Spring-cloud-stream-starter-rabbit -> 2.1.0.RELEASE RabbitMQ -> 3.7.7 Erlang -> 21,1 (1) Я...

Простите!Я получил те же вопросы от моих товарищей по команде. Они спросили меня, в чем разница...

Когда StreamListener требуется много времени (дольше, чем max.poll.interval.ms) для обработки...

Я настроил приложение на основе весенней загрузки с весенним облачным потоком.Я пытаюсь работать с...

Я создал сервис SpringBoot, который использует SpringCloud @StreamListener для обработки сообщений...

Когда я пытаюсь дать приведенную ниже команду в оболочке, я получаю приведенную ниже ошибку

Я могу отправлять сообщения через Kafka или RabbitMQ и использовать их с помощью @StreamListener....

Я создал источник SFTP (sftp-source-kafka: 2.1.0.M2), используя следующее определение на панели...

публикуя сообщение из моего кода облака весны в rabbitmq, не добавляя его в очередь rabbitmq, у...

Текущая настройка - я передаю данные из 16 разделенных разделов, выполняю соединения KTable-KTable...

KTable<Key1, GenericRecord> primaryTable = createKTable(key1, kstream, statestore-name);...

Я планирую реализовать конвейер обработки данных с использованием микросервисной архитектуры в Java

У меня есть 2 приложения Spring Cloud Stream «Scs-Processor» и «SCS-Sink», и я использую Kafka для...

Мне нужно запустить приложение весенней загрузки mapreduce в облачном потоке данных Spring. Обычно...