Short Lived Spring Cloud Stream

Sabari Published at Java

Sabari

Is it possible for a Spring Cloud Task to launch a Spring Cloud Stream (Source, Processor and Sink applications) as a short lived stream and track the stream processing status through the Task Repository?

Sabby Anandan

When using Spring Cloud Data Flow, you have the option to launch a Task/Batch-job from a Stream and vice-versa. The bi-directional communication is a convenient feature in SCDF.

A Task/Batch-job can emit events to a channel/topic and that can be an input to a Stream in SCDF - see sample.

Likewise, there are a variety of ways you can trigger to launch a Task/Batch-job from a Stream - more details here.

To centrally manage and monitor Streams and Tasks, SCDF provides tools to track them from the UI/Shell/APIs individually. The Stream status will be self-contained (available from persistent storage - see lifecycle), but it won't be part of Task Repository, though.

Collected from the Internet

Please contact [email protected] to delete if infringement.

edited at2020-10-19

Comments

0 comments

GCP Cloud Run Invoke another Projects Cloud function using short-lived credentials via 2 service accounts in separate Projects

TOP Ranking

Article

Short Lived Spring Cloud Stream

Short Lived Spring Cloud Stream

pump.io port in URL

How to import an asset in swift using Bundle.main.path() in a react-native native module

Failed to listen on localhost:8000 (reason: Cannot assign requested address)

Double spacing in rmarkdown pdf

SQL Server : need add a dot before two last character

Ambiguous use of 'init' with CFStringTransform and Swift 3

Resetting Value of <input type="time"> in Firefox

Retrieve Element Tag Value XML Using Bash

How to pass data to the ng2-bs3-modal?

JWT gives JsonWebTokenError "invalid token"

How to update azerothcore-wotlk docker container

C++ 16 bit grayscale gradient image from 2D array

redirect your computer port to url

Capybara Selenium Chrome opens About Google Chrome

mysql.connector.errors.InterfaceError: 2003: Can't connect to MySQL server on '127.0.0.1:3306' (111 Connection refused)

How to make thrown errors visible outside of a Promise?

JMeter: Why get error when try to save test plan

Should you provide dependent libraries in client jar?

Issue making model pop up onPress of flatlist

Message: element not interactable on accessing a tag python

Calling Doctrine clear() with an argument is deprecated