Support initial splitting in KafkaIO.ReadAll()
Open
io
java
kafka
P3
sub-task
- Dominant language
- Java
- Stars
- 8.7k
- Forks
- 4.7k
- Avg merge
- 1d 20h
- Merged PRs (30d)
- 196
Description
Imported from Jira [BEAM-10319](https://issues.apache.org/jira/browse/BEAM-10319). Original Jira may contain additional context.
Reported by: boyuanz.
Subtask of issue #20278
Contributor guide
Research direction
Start at the KafkaIO.ReadAll() entry point and read the linked Jira BEAM-10319 and parent issue #20278 for the missing requirements. The work is done when ReadAll() supports initial splitting as specified there, with the relevant Beam tests passing.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java, kafka
- Domain
- stream-processing
- Issue type
- Feature
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 25/100