You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Spongebob (Jira)" <ji...@apache.org> on 2023/12/15 09:26:00 UTC

[jira] [Created] (FLINK-33855) send flag message like checkpoint barrier

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)