Spring Cloud Stream multiple function definitions

Question

Is it possible to have reactive SCS application using functional (spring.cloud.function) style with multiple, separate functions / bindings? All examples I have found always register only one functional bean with default bindings input, output. I would like to register multiple, each with its own bindings.

Traditionally this could be done using spring-cloud-stream-reactive but it is now deprecated in favor of functional support.

score 22 · Accepted Answer · answered Oct 14 '19 at 13:10

22

Yes, it is possible in the latest snapshot and we'll be making RC1 shortly (were busy with the conference). Here is the link to the relevant docs. Basically you define as many function beans as you want and you declare how many functions you want to bind via spring.cloud.function.definition property delimiting function definitions with ;. For example, --spring.cloud.function.definition=foo;bar|baz where you are binding two functions; one is foo and second is bar|baz (composition of two functions). The binding names will be based on the naming convention. For example, foo-in-0 and foo-out-0.

answered Oct 14 '19 at 13:10

Oleg Zhurakousky

5,820
16
17

How will the binding name be for piped (composed) ones - foo;bar|baz ? And, what should I be mapping to my custom topic in Kafka Binder please ? – Angshuman Agarwal Jun 16 '20 at 21:50
1

@AngshumanAgarwal - based on my testing it seems to use a pipe in the name, eg. bar|baz-in-0, bar|baz-out-0 – Rod McCutcheon Sep 22 '20 at 00:54
1

Is it possible to have 2 functions in one application (foo; bar) where both functions have the same destination? – Ben Keil Dec 31 '20 at 11:55
1

@BenKeil, were you able to resolve it? – bluelabel Jun 08 '22 at 03:10

Spring Cloud Stream multiple function definitions

1 Answers1

Linked