[BEAM-9977] Build Kafka Read on top of Java SplittableDoFn

• Type: New Feature
• Status: In Progress
• Priority: P3
• Resolution: Unresolved
• Component/s: io-java-kafka
• Assignee: Unassigned
• Reporter: Boyuan Zhang
• Created: 12/May/20 22:59
• Updated: 04/Jun/22 16:25

Issue Links

• is required by: BEAM-5786 KafkaIO should support topic patterns
• links to: GitHub Pull Request #11715
• links to: GitHub Pull Request #11749
• links to: GitHub Pull Request #12557

Sub-Tasks

• Create CommitOffsetTransform to commit Kafka record offset: Resolved
• Support initial splitting in KafkaIO.ReadAll(): Open
• Create external transform builder for KafkaIO.ReadAll(): Open