apache / apache/rocketmq-flink
Introduce format parameter configuration to support different serialization and deserialization formats provided by Flink
Open
- Dominant language
- Java
- Stars
- 174
- Forks
- 104
- PR merge metrics
- No merged PRs in 30d
Description
The default format of the current connector is the delimited format, and other formats cannot be configured.
Introduce format parameter configuration to support different serialization and deserialization formats(like json, csv, avro, pb) provided by Flink.
Contributor guide
No contributing guide indexed for this repository
Research direction
Start by tracing how the RocketMQ source and sink currently perform delimited serialization and deserialization, then read the Flink format configuration APIs referenced by the issue. Done means the connector can configure the requested JSON, CSV, Avro, and Protocol Buffers formats instead of using only the default delimited format.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- stream-processing
- Issue type
- Feature
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Mostly clear
- Newbie friendliness
- 42/100