Hey all, we recently upgraded our flinkapp from flink 1.13 to flink 1.15, and we noticed an issue, our flinkapp has a kafka source, and it subscribes to 500+ topics, and when we remove the integration with one topic (stop subscribing to the topic and delete the topic on kafka), even the app no longer subscribes to the topic, it seems like it still kept some state for the previous topic, and because the topic is now deleted, it throws this error . I'm wondering if there's a way to resolve this?

Caused by: org.apache.kafka.common.errors.TimeoutException: Timeout of 60000ms expired before the position for partition crypto_float_inventory_backfill-2 could be determined