spring-cloud-stream Examples and Free Source Code

Kafka producer threads keep increasing...

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

Spring Cloud Stream send/consume message to different partitions with KafkaHeaders.Message_KEY...

java apache-kafka jhipster spring-cloud-stream

Configure Topics in Kafka broker itself or via Spring Cloud Stream...

java spring apache-kafka spring-cloud-stream

How to set transaction-id-prefix in app which has both consumer and producer-only transactions in Sp...

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

Spring Cloud Compatibility with Spring Boot...

java spring spring-boot kotlin spring-cloud-stream

Stop attempt to reconnect after first 'max' attempt...

spring-cloud-stream

How to get the ConsumerRecord object in StreamListener Consumer code...

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

How to configure multiple consumers to a single destination queue in spring cloud stream SQS binder...

java spring spring-cloud-stream

How to solve InvalidTopicException with multiplexed input topics in Spring Cloud Stream Kafka Stream...

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

Handling backpressure and avoiding rebalances on a slow consumer kafka...

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

how to write a function which produces data to different bindings based on custom logic...

java spring spring-cloud-stream

How to send a message with priority to RabbitMQ with StreamBridge...

rabbitmq priority-queue spring-cloud-stream spring-cloud-stream-binder

Spring Cloud Stream Kafka Producer force producer.flush...

apache-kafka spring-kafka spring-cloud-stream

Spring Cloud Data Flow: complex parallel processors scenario?...

spring-cloud-stream spring-cloud-dataflow

spring-cloud-stream retry policy per exception...

spring-cloud-stream spring-retry

Listing all my kafka consumers informations...

spring-kafka spring-cloud-stream

NoSuchMethodError when trying to map Kafka binder to input method...

spring-boot spring-cloud-stream

How to log around Spring Cloud Stream functions?...

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

spring cloud stream kafka binder retry...

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

Integration Test a Reactive Spring Cloud Stream...

spring spring-integration spring-cloud-stream spring-cloud-function

how to set concurrency (or other configurations) for ConcurrentKafkaListenerContainerFactory per Str...

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

Can I use a spring cloud stream function definition for multiple tenants (kafka binder)?...

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

Problem creating tests with Spring cloud streams kafka streams using embeddedKafka with MockSchemaRe...

java apache-kafka-streams spring-cloud-stream confluent-schema-registry embedded-kafka

How to patch spring cloud data flow starter application (add oracle driver to jdbc-source app)...

spring-cloud-stream spring-cloud-dataflow

After Migrating from spring boot 2.6.2 to 2.6.6 , getting org.springframework.context.ApplicationCon...

java spring spring-boot spring-cloud-stream

KafkaMessageChannelBinder cannot be cast to class TestSupportBinder...

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

Spring Cloud Bus with aws-kinesis...

spring-cloud spring-cloud-stream spring-cloud-bus

How to capture group specific messages with OutputDestination?...

spring-boot rabbitmq integration-testing spring-cloud spring-cloud-stream

How to rename the id header of a debezium mongodb connector outbox message...

mongodb apache-kafka spring-kafka spring-cloud-stream debezium

How to use the functional style on my RemoteChunkingManagerStepBuilderFactory?...

spring-batch spring-cloud-stream spring-integration-dsl spring-cloud-function spring-batch-integration