spring-cloud / spring-cloud/spring-cloud-stream
KafkaListenerEndpointRegistry alternate in SCS :
Nobody has claimed this yet.
- Dominant language
- Java
- Stars
- 1.1k
- Forks
- 646
- Avg merge
- 2d 3h
- Merged PRs (30d)
- 8
Description
Describe the issue
I have a use case : to get an boolean flag from an API(call happens every 5 min) and in case if its false i want to stop the message consumption . I can use KafkaListenerEndpointRegistry in spring kafka implementation .
But we are using spring cloud stream , and I don't see any code on how to turn off message consumption .
so I have used function composition , flagCheck|consume , But this does not turn off message consumption ,
Expected behavior
Some alternate to turn off the messages when flag is off and enable consumption when flag is ON in spring cloud stream.
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 tracing Spring Cloud Stream’s consumer lifecycle and comparing it with the KafkaListenerEndpointRegistry approach described in the issue. Review how function composition with flagCheck|consume behaves, then define the supported pause and resume behavior and document or test the resulting usage.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java, kafka, spring
- Domain
- backend, stream-processing
- Issue type
- Feature
- Difficulty
- 5/5
- Estimated time
- Over a week
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 30/100