The kafka server is not stable.

[b1ueseanoah]

The kafka server is not stable. Most of the reasons are because topics are maintained that have not been deleted after use.
It will probably be resolved soon.

[b1ueseanoah]

It will be removed through the corresponding source.

def delete_topic(self,topic_name, timeout = 1000):
delete_topics = [topic_name]
try:
# delete_topic
self.admin_client.delete_topics(topics=delete_topics,timeout_ms=timeout)
print(f"topic'{topic_name}' is deleted")
self.get_all_topics_info()
except UnknownTopicOrPartitionError:
print(f"topic '{topic_name}' is not exist.")
except Exception as e:
print(f"Error deleting topic: {e}")