spring-cloud / spring-cloud/spring-cloud-stream

Request: Roadmap / KIP-932 (Kafka Queues, Share Consumer) Support in Spring Cloud Stream Kafka Binder

Open
#3,145 4 comments 0 reactions 0 assignees View on GitHub

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

  1. Read the whole issue, then the project's contributing guide.
  2. Comment on the issue to say you are picking it up — it saves two people doing the same work.
  3. Fork the repository and make your change on a branch.
  4. 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

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.