Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
Description
As discussed in FLINK-5702, it might be a good idea to let the FlinkKafkaProducer flush on checkpoints by default. Currently, it is disabled by default.
It's a very simple change, but we should think about whether or not we want to break user behaviour, or have proper usage migration.
Attachments
Issue Links
- Blocked
-
FLINK-7913 Add support for Kafka default partitioner
- Open
- links to