Details
-
New Feature
-
Status: Resolved
-
Major
-
Resolution: Duplicate
-
None
-
None
Description
The kafka connector package only contains the FlinkFixedPartitioner implementation of the FlinkKafkaPartitioner.
The most common usecase I have seen is the need to spread the records across the Kafka partitions while keeping all messages with the same key together.
I'll put up a pull request with a very simple implementation that should make this a lot easier for others to use and extend.
Attachments
Issue Links
- is duplicated by
-
FLINK-11948 When kafka sink parallelism<kafka partition num,kafka data distribution unbalance
- Closed
- links to