[FLINK] Kafka/Pulsar offset state management
Open
enhancement
- Dominant language
- Scala
- Stars
- 1.6k
- Forks
- 657
- Avg merge
- 2d 14h
- Merged PRs (30d)
- 80
Description
### Description
~~
### Gluten version
None
Contributor guide
Research direction
The issue names Kafka/Pulsar offset state management but provides no files, tests, entry points, requirements, or acceptance criteria. Start by clarifying the intended behavior and locating the affected connector or state-management area; completion cannot be verified until the expected offset handling is defined.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- kafka
- Domain
- stream-processing
- Issue type
- Feature
- Difficulty
- 5/5
- Estimated time
- Over a week
- Activity status
- Quiet
- Clarity
- Needs clarification
- Newbie friendliness
- 10/100