[jira] [Created] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

Kevin Tseng created FLINK-33545: --- Summary: KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching Key: FLINK-33545 URL: https://issues.apache.org

[jira] [Created] (FLINK-33479) Add Rerouting support to KafkaSink

Kevin Tseng created FLINK-33479: --- Summary: Add Rerouting support to KafkaSink Key: FLINK-33479 URL: https://issues.apache.org/jira/browse/FLINK-33479 Project: Flink Issue Type: Improvement

Re: [DISCUSS] addition of Flink Script Operators

ic has been changed dynamically? >> Looking forward to hearing from you. >> >> Best regards, >> Jing >> >> On Wed, Aug 2, 2023 at 4:33 AM Kevin Tseng wrote: >> >> > Hello Dev Mailing List, >> > >> > I have a feature prop

[DISCUSS] addition of Flink Script Operators

Hello Dev Mailing List, I have a feature proposition that I am interested to hear more and to gather feedback from everyone on the mailing list. (please view this email in monospace font when possible) _*Proposal*_* * Currently, when Flink DataStream API is to be utilized, every data processin

[jira] [Created] (FLINK-31951) Mix schema record source creates corrupt record

Kevin Tseng created FLINK-31951: --- Summary: Mix schema record source creates corrupt record Key: FLINK-31951 URL: https://issues.apache.org/jira/browse/FLINK-31951 Project: Flink Issue Type