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.
The Catalog interface is responsible for reading and writing metadata such as database/table/views/UDFs from a registered catalog in the Flink. RocketMQ-Flink should support the RocketMQ implementation of the Catalog interface. It requires the features of RocketMQ Schema Registry.
The purpose of this issue
The
Cataloginterface is responsible for reading and writing metadata such as database/table/views/UDFs from a registered catalog in the Flink. RocketMQ-Flink should support the RocketMQ implementation of theCataloginterface. It requires the features of RocketMQ Schema Registry.