tanjialiang created FLINK-34089:
-----------------------------------
Summary: Missing check of subscribed and assigned topics at job
startup
Key: FLINK-34089
URL: https://issues.apache.org/jira/browse/FLINK-34089
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka
Affects Versions: kafka-3.0.2
Reporter: tanjialiang
When we unsubscribe a topic and still restore from the old state, the job will
still read data from the unsubscribed topic. I think we should check if that
the subscribed topic partitions match the assigned partitions, and throw an
error so the user can handle it.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
