Details
-
Improvement
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
None
-
None
Description
The fetched partitions list is only used when calling open(...) for a user supplied custom partitioner in FlinkKafkaProducer.
Therefore, we can actually only fetch the partition list if the user used a partitioner (right now we always do the partition fetching).
Attachments
Issue Links
- links to