search

apache / rocketmq-flink

RocketMQ integration for Apache Flink. This module includes the RocketMQ source and sink that allows a flink job to either write messages into a topic or read from topics in a flink job.
https://rocketmq.apache.org/
Apache License 2.0
139 stars 88 forks source link

Introduce format parameter configuration to support different serialization and deserialization formats provided by Flink #88

Open hackergin opened 1 year ago

hackergin commented 1 year ago

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.

humkum commented 1 year ago

I'd like to try this