Github user gyfora commented on the issue:
https://github.com/apache/flink/pull/3766
I liked the proposed API and I agree that it's probably best to keep the
old behaviour for the deprecated API.
I don't think the Kafka partition info fetching should be a huge problem as
it shouldnt happen too often and Kafka should be able to return the info if you
can write to it. We of course need some timeout/retry mechanism to not fail
unnecessarily.
The producer itself is not very resilient in case of errors in the current
state as it can't really handle the async errors it will just shut throw them
and fail.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
