defcreate_topics(topics:List[str],config:Dict[str,Optional[Union[str,int,float,bool,Any]]],logger_:Optional["LoggerProto"]=None,)->None:logger_=logger_orfaststream_logger"""Creates Kafka topics using the provided configuration."""admin_client=AdminClient({x:config[x]forxinADMINCLIENT_CONFIG_PARAMSifxinconfig})fs=admin_client.create_topics([NewTopic(topic,num_partitions=1,replication_factor=1)fortopicintopics])fortopic,finfs.items():try:f.result()# The result itself is NoneexceptExceptionase:# noqa: PERF203if"TOPIC_ALREADY_EXISTS"notinstr(e):logger_.log(logging.WARN,f"Failed to create topic {topic}: {e}")else:logger_.log(logging.INFO,f"Topic `{topic}` created.")