spring-cloud / spring-cloud/spring-cloud-stream
Request: Roadmap / KIP-932 (Kafka Queues, Share Consumer) Support in Spring Cloud Stream Kafka Binder
Nobody has claimed this yet.
- Dominant language
- Java
- Stars
- 1.1k
- Forks
- 646
- Avg merge
- 2d 3h
- Merged PRs (30d)
- 8
Description
Hello,
I’d like to ask about the roadmap for Spring Cloud Stream, specifically regarding support for KIP-932 (Kafka Queues, share consumers).
Context:
- Kafka 4.0+ has introduced KIP-932 (“share groups”) in early access / preview form.
- Spring for Apache Kafka (spring-kafka 4.x) already provides experimental support for share consumers (e.g.
ShareConsumerFactory,ShareKafkaMessageListenerContainer). - Many of us using Spring Cloud Stream with the Kafka binder would benefit from being able to experiment with (and later adopt) the new share group / queue consumption model.
Questions:
- Is there a public roadmap for Spring Cloud Stream (Kafka binder in particular)?
- Are there plans or timelines to integrate support for KIP-932 / share consumers once the feature stabilizes in Kafka and Spring Kafka?
Why this matters:
KIP-932 opens new scaling and consumption models (queue-like semantics, cooperative multi-consumer partition consumption) that could be very valuable in microservice architectures using Spring Cloud Stream.
Looking forward to your guidance on the roadmap and how/when KIP-932 might be supported.
Contributor guide
No contributing guide indexed for this repository
First steps
- Read the whole issue, then the project's contributing guide.
- Comment on the issue to say you are picking it up — it saves two people doing the same work.
- Fork the repository and make your change on a branch.
- Open a pull request that references the issue number.
Research direction
Start by reviewing the Spring Cloud Stream Kafka binder and the Spring Kafka share-consumer classes named in the issue, including ShareConsumerFactory and ShareKafkaMessageListenerContainer. The issue is asking for roadmap and timeline guidance rather than naming a file, test, or concrete implementation; done would require an explicit decision about KIP-932 support and its expected timing.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java, kafka, spring
- Domain
- backend, distributed-systems, stream-processing
- Issue type
- Feature
- Difficulty
- 5/5
- Estimated time
- Over a week
- Activity status
- Active
- Clarity
- Needs clarification
- Newbie friendliness
- 20/100