Я пытаюсь следовать одному из примеров кодов для Kafka Stream, чтобы убедиться, что мой потребитель...
Я построил поток на потоке данных Spring Cloud, который использует пользовательский процессор, и я...
У меня есть простое приложение, которое получает сообщение и пишет в другую тему, используя...
У нас есть приложение Spring Cloud Stream, использующее Kafka.Требование заключается в том, что на...
Я использую подшивку RabbitMQ. Spring Cloud Stream позволяет разработчикам повторять попытки при...
Я новичок в Kafka и Spring Cloud и отправляю сообщение с ключом в тему kafka и пытаюсь прочитать...
У меня есть @StreamListener, который принимает строку @Payload.Для тестирования этого класса...
Я пытаюсь создать простое приложение облачного потока с привязкой kafka.Позвольте мне описать...
Я настроил DLQ по умолчанию следующим образом: spring: cloud: stream: rabbit: default: consumer:...
в моем приложении Spring Cloud Spring (с Kafka) я хотел бы написать KStream<SomeKey,...
После обновления до весенней загрузки 2.1.6.RELEASE запуск приложения завершается неудачно: Полевая...
У меня есть продюсер, который получает партии предметов для помещения в очередь. Я хотел бы знать,...
Чтобы сравнить производительность приложения Spring Cloud Stream (с Kafka), использующего RocksDB...
Я создаю приложение на основе SpringCloud Stream, а тип обмена - это тема, и сообщение отправляется...
Я настраиваю проект, сгенерированный с помощью jhipster, и я хочу отключить конфигурацию облака...
Мое приложение успешно отправляет сообщения Kafka, но только после инициализации Kafka.Перед этим я...
, поэтому я читал этот учебник для настройки RabbitMQ и SpringBoot. В определенный момент сказано: В...
У меня есть приложение весенней загрузки (v.1.57), которое использует Spring Cloud Stream (v1.3.0)...
Я храню сообщения из темы Kafka в KeyValueStore, чтобы я мог запросить их позже. Я создаю таблицу...
В настоящее время мы используем Spring Cloud Stream для предоставления SubscribableChannel для...
Мы используем Google Pub / Sub с org.springframework.cloud.stream.annotation.StreamListener из...
Мы используем консул для распространения конфигурации и обнаружения службы вручную (используется...
Я настроил приложение Spring Cloud Stream Kafka для использования транзакций ( полный исходный код...
Я реализую KStream-GlobalKTable-Join с использованием Spring-Cloud-Stream, и я столкнулся с...
Я обновил свой весенний поток с 1.3.0 до 2.1.2, и сериализатор по умолчанию был изменен с Kyro...