A modern programming language that makes developers happier.

kotlinlang

Hi, I'm trying to setup a Spring Cloud Streams app that talks with Kafka, but configuring it has been a nightmare. What I'm trying to do is: have to pipelines made of composing multiple functions. Have separate series for input and output of each pipeline's consumer and producer. Handle schema registry login info. Have a producer pick a topic based on message content.

Not kotlin specific, but our team uses Spring Cloud Streams extensively and are big fans of it, so willing to help out anyway

&gt; <https://docs.spring.io/spring-cloud-stream/docs/3.1.2/reference/html/spring-cloud-stream.html#_functional_composition|have to pipelines made of composing multiple functions>
&gt; Have separate series for input and output of each pipeline’s consumer and producer.
Just have multiple `spring.cloud.function.definition` properties separated by `;`

&gt; Handle schema registry login info 
This is most likely configured in the kafka binder rather than w/ spring cloud streams itself.

&gt; <https://docs.spring.io/spring-cloud-stream/docs/3.1.2/reference/html/spring-cloud-stream.html#_spring_cloud_stream_sendto_destination|Have a producer pick a topic based on message content.>
edit: if you know the destinations ahead of time you can also  configure<https://docs.spring.io/spring-cloud-stream/docs/3.1.2/reference/html/spring-cloud-stream.html#_functions_with_multiple_input_and_output_arguments| multi-output via flux tuple>