Subject: Deletion of topic from a pattern in KafkaConsumer if auto-create is true will always recreate the topic


Given

https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java#L471

it seems that if

*  I have a regex pattern for consuming a bunch of topics
* auto create is turned on

then even if I do this

* suspend the pipe with SP
* delete the topic
* start the pipe

It will recreate the topic, b'coz the state has it and the check is against
the pattern rather then against the cluster metadata....in case  auto
create is turned off it will throw an exception ( I think )
The question thus is, as to how can we safely delete a topic from our kafka
cluster without either a recreation ( auto create on ) or exception ( auto
create off ) when restarting from a SP, where the restore  state had that
topic..

Thanks much,

Visha.