[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/bro

[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

[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: Bug