[VL][FLINK] Support json/raw format deserialize for kafka data source reader
Open
enhancement
- Dominant language
- Scala
- Stars
- 1.6k
- Forks
- 657
- Avg merge
- 2d 21h
- Merged PRs (30d)
- 85
Description
### Description
support json/row format deserialize for kafka source reader
### Gluten version
None
Contributor guide
Research direction
Start by locating the Kafka source reader and its existing deserialization paths. Determine how JSON and raw formats should be handled, then verify that Kafka data source reads deserialize both formats correctly; the issue names no specific files or tests.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- kafka, scala
- Domain
- stream-processing
- Issue type
- Feature
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 35/100