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

When will the SQL92 filter mode be supported? #21

Closed ChoviWu closed 1 year ago

ChoviWu commented 2 years ago

At present, we do not use the tag subscription mode, but use the sql92 expression to filter messages, and can support custom extended messages beforehook and afterhook

SteNicholas commented 2 years ago

@ChoviWu , do you have interest to support this feaure? IMO, the sql92 expression could be the DDL table option to configure the consumer.

GOODBOY008 commented 2 years ago

Hi, @SteNicholas .I have interest to support this feature.