Spongebob created FLINK-33855:
---------------------------------
Summary: send flag message like checkpoint barrier
Key: FLINK-33855
URL: https://issues.apache.org/jira/browse/FLINK-33855
Project: Flink
Issue Type: Technical Debt
Components: Table SQL / API
Reporter: Spongebob
I use flinksql to consume kafka message. Now I want to send one specific
message to that kafka topic, and I hope the sink table that use user defined
connector can receive this specific message. maybe it sounds like the barrier
to trigger checkpoints. Is there anyway to solve this debt ?
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
