def METHOD_NAME(self) -> Optional[Iterator[TableMetadata]]:
    """
    Return an iterator generating TableMetadata for all of the schemas.
    """
    for schema_version in self._get_raw_extract_iter():
        subject = schema_version.subject
        schema = schema_version.schema.raw_schema
        LOGGER.info((f'Subject: {subject}, '
                     f'Schema: {schema}'))
        try:
            yield KafkaSchemaRegistryExtractor._create_table(
                schema=schema,
                subject_name=subject,
                cluster_name=schema.get(
                    'namespace', 'kafka-schema-registry'
                ),
                schema_name=schema.get('name', ''),
                schema_description=schema.get('doc', None),
            )
        except Exception as e:
            logger.warning(f'Failed to generate table for {subject}: {e}')
            continue