Arvid Heise created FLINK-38681:
-----------------------------------
Summary: Fix threading model of KafkaEnumerator
Key: FLINK-38681
URL: https://issues.apache.org/jira/browse/FLINK-38681
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka
Affects Versions: kafka-5.0.0
Reporter: Arvid Heise
Assignee: Arvid Heise
Fix For: kafka-5.0.0
FLINK-38453 broke the threading model of KafkaEnumerator by accessing some of
the data structures from the worker thread without synchronization. The
migration path also triggers NPE.
We should partially revert FLINK-38453 to restore the threading model (and fix
an original issue) and do migration lazily instead.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
