spring-cloud/spring-cloud-stream

View on GitHub

Framework for building Event-Driven Microservices

Stars: 1.1k
Forks: 646
Open beginner issues: 0
Indexed issues: 123
Avg merge: 2d 3h
Merged PRs (30d): 8

Dominant language: Java
License: Apache-2.0
Last GitHub push: Sep 15, 2026
Latest indexed: Sep 19, 2026
Contributing guide: No contributing guide
Code of conduct: Code of conduct
Beginner labels: No beginner labels indexed

Beginner friendly Everything

Open All

123 open issues indexed

Provide a way to customize the ObjectMapper used in AMCB Open

enhancement waiting-on-feedback

Difficulty 5/5 Over a week Newbie friendliness 30/100

spring-cloud/spring-cloud-stream#2876 · 1 comment · 1 reaction · Opened Dec 21, 2023
Feature Request: Add maxAge to the binder properties Open

enhancement

Difficulty 3/5 1-2 days Newbie friendliness 45/100

spring-cloud/spring-cloud-stream#2856 · 1 reaction · Opened Nov 21, 2023
RabbitMQ: Ensure Binding has a Group When Using a Quorum Queue Open

enhancement RABBITMQ-BINDER

Difficulty 3/5 1-2 days Newbie friendliness 48/100

spring-cloud/spring-cloud-stream#2839 · 1 comment · Opened Oct 27, 2023
Add dead-letter-policy support to SCSt Pulsar Binder Open

enhancement PULSAR-BINDER

spring-cloud/spring-cloud-stream#2830 · 1 assignee · Opened Oct 17, 2023
Feature request: enable recreation of kafka producer during runtime with spring-cloud-stream Open

waiting-on-feedback

Difficulty 5/5 Over a week Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2827 · 2 comments · Opened Oct 10, 2023
spring-cloud-stream-binder-kafka-reactive ignores message converter configuration for producer message handler Open

enhancement

Difficulty 3/5 1-2 days Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2810 · Opened Sep 15, 2023
Consider adding @GeneratedValue and @SequenceGenerator to the Schema entity class in Schema Registry Open

enhancement

Difficulty 3/5 1-2 days Newbie friendliness 30/100

spring-cloud/spring-cloud-stream#2766 · Opened Jul 5, 2023
Reactive Kafka binder should look at the partition header added by Spring Cloud Stream Open

enhancement

Difficulty 4/5 3-5 days Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2753 · Opened Jun 13, 2023
KafkaStreamsBinder bootstrapping refactor Open

enhancement

Difficulty 4/5 3-5 days Newbie friendliness 25/100

spring-cloud/spring-cloud-stream#2739 · Opened May 20, 2023
Kafka-streams health check on state stores Open

enhancement

Difficulty 4/5 3-5 days Newbie friendliness 38/100

spring-cloud/spring-cloud-stream#2733 · 1 comment · 2 reactions · Opened May 15, 2023
Expose KafkaConsumer in ReceiverOptionsCustomizer.addAssignListener() - parity with KafkaBindingRebalanceListener Open

documentation REACTIVE-KAFKA-BINDER

spring-cloud/spring-cloud-stream#2727 · 6 comments · 7 reactions · 1 assignee · Opened May 9, 2023
Spring Cloud Stream routing-to channel (using spring.cloud.stream.function.definition) gives ClassCastException Open

waiting-on-feedback

spring-cloud/spring-cloud-stream#2719 · 8 comments · 1 reaction · 1 assignee · Opened Apr 27, 2023
Add Transactional Support for Reactive Binder Open

feature REACTIVE-KAFKA-BINDER

Difficulty 5/5 Over a week Newbie friendliness 30/100

spring-cloud/spring-cloud-stream#2695 · Opened Apr 4, 2023
ImmediateAcknowledgeAmqpException lost due to globalErrorChannelCustomizer bean. Open

Difficulty 4/5 3-5 days Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2671 · Opened Mar 13, 2023
Trace ID logging inconsistencies across kafka binder and reactor kafka binder Open

Difficulty 4/5 3-5 days Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2647 · 6 comments · 2 reactions · Opened Feb 9, 2023
Consider an Actuator endpoint to show the state of the registered schemas Open

feature

spring-cloud/spring-cloud-stream#2592 · 1 assignee · Opened Dec 15, 2022
Back port Error Handling fix to v3 Open

Difficulty 4/5 3-5 days Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2591 · 1 comment · Opened Dec 14, 2022
Move only specific exception to DLQ in Spring Cloud Stream Open

Difficulty 4/5 3-5 days Newbie friendliness 25/100

spring-cloud/spring-cloud-stream#2585 · Opened Dec 12, 2022
Instrumentation of the Kafka consumers to allow the configuration of MDC logging Open

Difficulty 4/5 3-5 days Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2577 · 6 comments · Opened Dec 5, 2022
Feature Requests: Reactive StreamBridge Open

feature REACTIVE-KAFKA-BINDER

spring-cloud/spring-cloud-stream#2557 · 2 comments · 5 reactions · 1 assignee · Opened Nov 9, 2022
BatchMessagingMessageConverter header mapper Open

bug KAFKA-BINDER

Difficulty 4/5 3-5 days Newbie friendliness 20/100

spring-cloud/spring-cloud-stream#2550 · 3 comments · Opened Nov 3, 2022
MessageRoutingCallback and Routing-expression not worked for event routing Open

waiting-on-feedback

Difficulty 4/5 3-5 days Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2549 · 4 comments · Opened Nov 2, 2022
Could you add batch mode support to the upcoming spring-cloud-stream-binder-kafka-reactive ? Open

enhancement

Difficulty 4/5 3-5 days Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2527 · 4 comments · Opened Oct 7, 2022
Enable Reactive Kafka binder for Graal native compilation Open

AOT / NATIVE REACTIVE-KAFKA-BINDER

Difficulty 4/5 3-5 days Newbie friendliness 25/100

spring-cloud/spring-cloud-stream#2463 · Opened Jul 28, 2022
Consider adding KafkaStreams 'wait for started' API to test util Open

Difficulty 3/5 1-2 days Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2454 · 1 reaction · Opened Jul 8, 2022
[Feature Request] Support loading customzied configuration for kafka binder configuration to kafka binder's context Open

enhancement

Difficulty 5/5 Over a week Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2446 · 1 reaction · Opened Jun 24, 2022
No possibility to create function definition templates Open

Difficulty 5/5 Over a week Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2406 · Opened May 24, 2022
Multiple partition support per Sink instance Open

Difficulty 4/5 3-5 days Newbie friendliness 25/100

spring-cloud/spring-cloud-stream#2336 · Opened Mar 30, 2022
How to bind to two groups with the same destination? Open

Difficulty 4/5 3-5 days Newbie friendliness 25/100

spring-cloud/spring-cloud-stream#2334 · 1 reaction · Opened Mar 30, 2022
Add support for attaching user application to a binder at startup time Open

KAFKA-BINDER

Difficulty 5/5 Over a week Newbie friendliness 25/100

spring-cloud/spring-cloud-stream#2333 · 2 comments · Opened Mar 30, 2022
RabbitMessageChannelBinder fails to initialize LocalizedQueueConnectionFactory if ssl.enabled is not specified Open

Difficulty 3/5 1-2 days Newbie friendliness 48/100

spring-cloud/spring-cloud-stream#2331 · Opened Mar 30, 2022
Provide an extension point for setting offsets before starting container Open

Difficulty 4/5 3-5 days Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2326 · Opened Mar 30, 2022
Accept multiple ListenerContainerCustomizers Open

Difficulty 3/5 1-2 days Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2325 · 1 reaction · Opened Mar 30, 2022
Support customize message before sending to DLQ Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

spring-cloud/spring-cloud-stream#2324 · 4 reactions · Opened Mar 30, 2022
AdminClient / KafkaAdmin with merged standard kafka and binder properties Open

KAFKA-BINDER

Difficulty 5/5 Over a week Newbie friendliness 30/100

spring-cloud/spring-cloud-stream#2322 · Opened Mar 30, 2022
Cannot disable nativeEncoding/nativeDecoding in general for Kafka Streams binder Open

KAFKA-BINDER

Difficulty 5/5 Over a week Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2321 · Opened Mar 30, 2022
Inbound KTable (and possibly GlobalKTable) ignoring nativeDecoding=false Open

KAFKA-BINDER

Difficulty 4/5 3-5 days Newbie friendliness 42/100

spring-cloud/spring-cloud-stream#2320 · Opened Mar 30, 2022
@EmbeddedKafka not working properly with GlobalKTable and transformer Open

KAFKA-BINDER waiting-on-feedback

Difficulty 4/5 3-5 days Newbie friendliness 25/100

spring-cloud/spring-cloud-stream#2319 · 2 comments · Opened Mar 30, 2022
Be able to discard messages using the Function Router Open

Difficulty 5/5 Over a week Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2278 · Opened Feb 8, 2022
BindigsLifecycleController returning invalid type Open

Difficulty 3/5 1-2 days Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2264 · 1 reaction · Opened Jan 11, 2022
Address fallback logic since SPR-17503 was resolved Open

Difficulty 3/5 1-2 days Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2260 · Opened Dec 28, 2021
Fix inconsistency in consuming messages in batches Open

Difficulty 5/5 Over a week Newbie friendliness 20/100

spring-cloud/spring-cloud-stream#2258 · 1 comment · 1 reaction · Opened Dec 21, 2021
StreamBridge does not allow to switch between different producer configs due to internal caching Open

Difficulty 4/5 3-5 days Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2257 · Opened Dec 21, 2021
Could spring stream add a annotation "StreamFunction" ? Open

waiting-on-feedback

Difficulty 5/5 Over a week Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2247 · 1 comment · 1 reaction · Opened Nov 20, 2021
Replacement for DirectProcessor Open

Difficulty 4/5 3-5 days Newbie friendliness 25/100

spring-cloud/spring-cloud-stream#2242 · Opened Nov 1, 2021
In lieu of some recent work in cloud-commons consider using DefaultsBindHandlerAdvisor Open

Difficulty 3/5 1-2 days Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2238 · Opened Oct 22, 2021
Spring Cloud function is throwing error "Type must be one of Supplier, Function or Consumer" for non functional beans Open

waiting-on-feedback

Difficulty 4/5 3-5 days Newbie friendliness 35/100

spring-cloud/spring-cloud-stream#2232 · 2 comments · Opened Oct 6, 2021
Allow suppliers and routing function to co-exist Open

enhancement

spring-cloud/spring-cloud-stream#2199 · 1 assignee · Opened Jul 21, 2021
discrepancy between kafka and rabbitmq binder Open

waiting-on-feedback

spring-cloud/spring-cloud-stream#2185 · 6 comments · 2 assignees · Opened Jun 10, 2021
Add (javax.)Validation Support for functional interface Open

ideal-for-contribution

Difficulty 4/5 3-5 days Newbie friendliness 45/100

spring-cloud/spring-cloud-stream#2182 · 3 comments · 1 reaction · Opened Jun 3, 2021

spring-cloud/spring-cloud-stream

Get new issues in your inbox