Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Provide a way to support Consumer#enforceRebalance #3011

Closed
sobychacko opened this issue Jan 31, 2024 · 0 comments · Fixed by #3021
Closed

Provide a way to support Consumer#enforceRebalance #3011

sobychacko opened this issue Jan 31, 2024 · 0 comments · Fixed by #3021
Labels
backport-to-3.0.x (obsolete) for: backport-to-3.1.x (obsolete) status: backported type: enhancement
Milestone
3.2.0-M1

Comments

@sobychacko
Copy link
Contributor

Currently, we can use the RecordInterceptor to access the consumer and trigger an enforceRebalance. Explore an option to see if we can support this operation as a first-class citizen from the container. Fore more details: https://kafka.apache.org/36/javadoc/org/apache/kafka/clients/consumer/Consumer.html#enforceRebalance()
sobychacko added a commit to sobychacko/spring-kafka that referenced this issue Feb 8, 2024
@sobychacko
spring-projectsGH-3011: Support enforced consumer rebalance
42e8b4f 
Fixes: spring-projects#3011

Kafka consumer API supports an enforced rebalance. Provide an option
via the message listener container to trigger this operation.
sobychacko added a commit to sobychacko/spring-kafka that referenced this issue Feb 8, 2024
@sobychacko
spring-projectsGH-3011: Support enforced consumer rebalance
a2bda98 
Fixes: spring-projects#3011

Kafka consumer API supports an enforced rebalance. Provide an option
via the message listener container to trigger this operation.
@sobychacko sobychacko mentioned this issue Feb 8, 2024
Merged
@artembilan artembilan added this to the 3.2.0-M1 milestone Feb 8, 2024
artembilan pushed a commit that referenced this issue Feb 8, 2024
@sobychacko
GH-3011: Support enforced consumer rebalance
eb110c0 
Fixes: #3011

Kafka consumer API supports an enforced rebalance. 
Provide an option via the message listener container to trigger this operation.

* Update spring-kafka-docs/src/main/antora/modules/ROOT/pages/kafka/receiving-messages/enforced-rebalance.adoc

**Auto-cherry-pick to `3.1.x`**
artembilan pushed a commit that referenced this issue Feb 9, 2024
@sobychacko @artembilan
GH-3011: Support enforced consumer rebalance
e518f1a 
Fixes: #3011

Kafka consumer API supports an enforced rebalance.
Provide an option via the message listener container to trigger this operation.

* Update spring-kafka-docs/src/main/antora/modules/ROOT/pages/kafka/receiving-messages/enforced-rebalance.adoc

**Auto-cherry-pick to `3.1.x`**
# Conflicts:
#	spring-kafka/src/main/java/org/springframework/kafka/listener/AbstractMessageListenerContainer.java
@spring-builds spring-builds mentioned this issue Feb 9, 2024
Closed
artembilan pushed a commit that referenced this issue Feb 26, 2024
@sobychacko @artembilan
GH-3011: Support enforced consumer rebalance
ef8c040 
Fixes: #3011

Kafka consumer API supports an enforced rebalance.
Provide an option via the message listener container to trigger this operation.
@spring-builds spring-builds mentioned this issue Feb 26, 2024
Closed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
backport-to-3.0.x (obsolete) for: backport-to-3.1.x (obsolete) status: backported type: enhancement
Projects
None yet
Milestone
3.2.0-M1
Development

Successfully merging a pull request may close this issue.

GH-3011: Support enforced consumer rebalance sobychacko/spring-kafka
3 participants
@sobychacko @artembilan @spring-builds