|
|
|
FLINK-23838
|
FLINK-22902
Add FLIP-33 metrics to new KafkaSink
|
Fabian Paul
|
Fabian Paul
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-23814
|
FLINK-22902
Test FLIP-143 KafkaSink
|
Hang Ruan
|
Fabian Paul
|
|
Closed |
Done
|
|
|
|
|
|
|
|
FLINK-23735
|
FLINK-22902
Migrate BufferedUpsertSinkFunction to FLIP-143
|
Fabian Paul
|
Fabian Paul
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-23710
|
FLINK-22902
Move sink to org.apache.kafka.conntor.kafka.sink package
|
Fabian Paul
|
Fabian Paul
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-23664
|
FLINK-22902
Write documentation for new KafkaSink
|
Fabian Paul
|
Fabian Paul
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-23640
|
FLINK-22902
Create a KafkaRecordSerializationSchemas valueOnly helper
|
Fabian Paul
|
Fabian Paul
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-23639
|
FLINK-22902
Migrate Table API to new KafkaSink
|
Fabian Paul
|
Fabian Paul
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-23124
|
FLINK-22902
Implement exactly-once Kafka Sink
|
Fabian Paul
|
Fabian Paul
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-23123
|
FLINK-22902
Implement at-least-once Kafka Sink
|
Fabian Paul
|
Fabian Paul
|
|
Resolved |
Fixed
|
|
|
|
|