[ 
https://issues.apache.org/jira/browse/FLINK-33855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Martijn Visser closed FLINK-33855.
----------------------------------
    Resolution: Invalid

> 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
>            Priority: Minor
>
> 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)

Reply via email to