Aleksandr Savonin created FLINK-39822:
-----------------------------------------
Summary: All createTopics calls in tests should wait for partition
assignment
Key: FLINK-39822
URL: https://issues.apache.org/jira/browse/FLINK-39822
Project: Flink
Issue Type: Improvement
Components: Connectors / Kafka
Reporter: Aleksandr Savonin
We fixed a few occurrences previously seen in CI (a topic metadata propagation
race addressed by {*}FLINK-39234{*}, {*}FLINK-39699{*}, and {*}FLINK-39723{*}).
However, to prevent similar issues in other tests, I want to use this ticket as
an umbrella ticket to track all calls that remain unprotected and fix them here.
So far, I have found:
{{KafkaSinkExternalContext.createTopic}} (not currently observed in CI, but I
suggest to fix it beforehand).
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
