spring-cloud-stream-samples
spring-cloud-stream-samples copied to clipboard
spring-cloud
Samples for Spring Cloud Stream
See this issue: https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/185
Hi Team, I am trying to find best solution on Spring steam with functions. My requirement like below, We will get request data in a topic(X) and have to respond...
Can you please add an example how to use branching in a reactive way? ```java Predicate testPredicate = (k, v) -> ??? @Bean @SuppressWarnings("unchecked") public Function map() { return reviews...
Hi @sobychacko Do we have plans for adding the support for NATS/Redis Streams?
https://github.com/spring-cloud/spring-cloud-stream-samples/blob/9207c99b7ce24a8fac8a41f81e244796143bda4f/processor-samples/uppercase-transformer/pom.xml#L19 need to change to : Hoxton.SR5 If trying just that proyect otherwise you will have this error: Cannot resolve org.springframework.cloud:spring-cloud-stream-binder-kafka:unknown
Hi, could you please update `https://github.com/spring-cloud/spring-cloud-stream-samples/tree/master/kinesis-samples/kinesis-produce-consume` with sample how to handle errors when sending messages to Kinesis Stream? Errors I'm thinking about are: invalid stream (non existing) name, missing PutRecord...
could you please update the DLQ example, it s still based on serdeError (deprecated) instead of deserializationExceptionHandler
Hello, Could be used Kafka Streams with RambbitMQ only? I mean something like this: 1. Producer - publish data to a Rabbit queue: Supplier< Flux < Object1 > > publish()...
Hey guys It'd be great for me and other new people that are new to Spring Cloud Stream & Spring Cloud Function to be able to understand what is the...
