python (12.9k questions)
javascript (9.2k questions)
reactjs (4.7k questions)
java (4.2k questions)
java (4.2k questions)
c# (3.5k questions)
c# (3.5k questions)
html (3.3k questions)
Using Spring Cloud Stream Kafka Streams with Avro input/output with nativeEncoding/decoding=false
We're testing the use of Kafka Streams via Spring Cloud Stream function support with Avro input/output records, but setting nativeEncoding=false and nativeDecoding=false in order to use a custom Messa...

José María Lora
Votes: 0
Answers: 1
Dynamic destination in Spring Cloud Stream from Azure Event Hub to Kafka
I'm trying to use Spring Cloud Stream to process messages sent to an Azure Event Hub instance. Those messages should be routed to a tenant-specific topic determined at runtime, based on message conten...
Riccardo Bellini
Votes: 0
Answers: 1
BeanInitializationException with NPE during initialization when branching with Kafka Streams
I am currently working on an application using Spring Cloud Stream framework and I'm having troubles upgrading kafka deprecated method KStream.branch() to KStream.split(). I used to seperate my KStrea...
MatthiasN
Votes: 0
Answers: 0
How to gracefully exit a spring cloud function definition on exception scenario?
I am using spring cloud function chaining in my project like below:
spring.cloud.function.definition = func_A|func_B|func_C|func_D
The above definition will pipe the result of func_A to func_B, and f...
RAM KUMAR
Votes: 0
Answers: 1