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)