spring-cloud-stream Examples and Free Source Code

How can I conditionally deserialize a Kafka message based on some condition?...

spring-kafka spring-cloud-stream

How to use Spring Stream Application supplier as a proxy?...

spring-integration spring-kafka spring-cloud-stream spring-cloud-function spring-cloud-stream-binder

GlobalKTable as QueryableStore with Kafka Streams Binder...

apache-kafka spring-kafka apache-kafka-streams spring-cloud-stream spring-cloud-stream-binder-kafka

Apply a dynamic group value in Spring Cloud Stream...

rabbitmq spring-cloud-stream spring-rabbit

Checkpointing and Locking in Amazon Kinesis using PostgreSQL...

java postgresql spring-boot spring-cloud-stream amazon-kinesis

Can we use PostgreSQL instead of default dynamo db for checkpointing and locking in case of consumin...

java postgresql spring-boot spring-cloud-stream amazon-kinesis

While implementing dead-letter queue (DLQ), a channel error is throw...

spring-cloud-stream spring-rabbit

Spring Cloud dynamic consumer creation, message type is lost...

spring-boot spring-cloud-stream spring-context

Spring Cloud Streams ignores parameters of producer...

apache-kafka spring-cloud-stream

Amazon Kinesis Stream name is not taken as per provided application.yml file...

spring-boot spring-cloud-stream amazon-kinesis

Spring Cloud Stream Multiple Kafka Clusters Configuration...

spring spring-cloud spring-cloud-stream spring-cloud-stream-binder-kafka spring-cloud-stream-binder

Producer configurations for PublishConfirm...

spring-cloud-stream

Spring cloud stream project, kafka DLQ configuration is ignored for Leyton version...

spring-boot spring-kafka spring-cloud-stream spring-cloud-stream-binder-kafka

How to handle org.apache.kafka.common.errors.SslAuthenticationException: SSL handshake failed...

apache-kafka spring-cloud-stream

Producing message for RabbitMq using Supplier...

rabbitmq spring-cloud spring-cloud-stream spring-cloud-stream-binder

How to bind the same topic to multiple functions with the Kafka Streams binder in Spring Cloud Strea...

spring-boot apache-kafka-streams spring-cloud-stream spring-cloud-stream-binder-kafka

Spring cloud stream doesn't deserialise kafka message automatically for specified configuration...

java spring-boot apache-kafka spring-cloud-stream spring-cloud-stream-binder-kafka

Possible to set "Ack Immediately" using Solace Spring Cloud Stream Binder?...

spring-cloud-stream solace

Unable to Serialize Spring Cloud Streams with Avro (Custom Serdes)...

apache-kafka spring-kafka avro spring-cloud-stream

Batch processing error encountered after upgrade to Spring Cloud Stream Binder for Kinesis 4.0.0...

spring-cloud-stream spring-cloud-stream-binder spring-cloud-stream-binder-kinesis

Skip Filtering in Spring Cloud Stream Workflow...

spring-cloud-stream spring-cloud-function

Spring Cloud Dataflow kafka-source-kafka throwing error...

spring-cloud-stream spring-cloud-dataflow

Cloud Kafka with spring boot gives me errors...

java spring-boot spring-cloud spring-cloud-stream spring-cloud-function

Channels not mapped when testing with Spring Cloud Stream using Spring Cloud Function...

spring-cloud spring-cloud-stream

StreamBridge is overriding headers set for Kafka using CloudEventMessageBuilder...

spring-cloud-stream

Migration Spring Cloud Stream v2 to Spring Cloud Stream v4 for org.springframework.cloud.stream.mess...

java spring spring-boot spring-cloud-stream

Kafka reactive binder consumer concurrency option is pointless...

spring-cloud-stream

Kafka stream: PolicyViolationException: Topic replication factor must be 3...

apache-kafka apache-kafka-streams spring-kafka spring-cloud-stream

@StreamListener doesn't work for secured Kafka streaming, TopologyException...

java spring apache-kafka spring-cloud-stream spring-cloud-stream-binder-kafka

Bind a consumer queue name to an existing exchange...

spring-cloud-stream