В настоящее время я застрял в простом примере ручного управления смещениями и фиксациями Kafka.У...

Я пытаюсь использовать Преобразование сообщений на основе схемы Avro в приложении Spring Cloud...

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

Задача : Я пытаюсь прочитать большой файл построчно и помещаю сообщение в RabbitMQ. Я хочу...

Я использую Spring Cloud Stream 1.3.2.RELEASE , чтобы опубликовать строковое сообщение для Кафки....

Этот вопрос задавался и решался пару раз, но из-за моих очень ограниченных знаний я не могу найти...

У меня есть задание Dataflow, которое записывает авро-сообщения в PubSub: PubsubIO

У меня есть требование разделять сообщения и обрабатывать их по одному.Если какое-либо из сообщений...

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

Я пытаюсь прочитать KTable, используя проект spring-cloud-stream-binder-kafka-streams. Можем ли мы...

Может кто-нибудь предложить мне способы передачи метаданных между шагами канала SCDF? Вот некоторые...

Я использую начальные приложения SCDF, такие как источник 'file', в моем конвейере данных. Есть ли...

Я сделал все возможные совпадения и перепутал зависимости, но все еще не смог записать трассировки...