yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-06-27 05:03:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

doc(mysql,kafka): fix support status (#13812)

Browse Source 
Co-authored-by: Harshal Sheth <hsheth2@gmail.com>
This commit is contained in:
Aseem Bansal 2025-06-19 16:51:14 +05:30 committed by GitHub
parent 4aa3a928c0
commit 135e905e7c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 23 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
metadata-ingestion/src/datahub/ingestion/source/kafka/kafka.py
View File

@ -189,6 +189,21 @@ class KafkaConnectionTest:
SourceCapability.SCHEMA_METADATA,
"Schemas associated with each topic are extracted from the schema registry. Avro and Protobuf (certified), JSON (incubating). Schema references are supported.",
)
@capability(
SourceCapability.DATA_PROFILING,
"Not supported",
supported=False,
)
@capability(
SourceCapability.LINEAGE_COARSE,
"Not supported. If you use Kafka Connect, the kafka-connect source can generate lineage.",
supported=False,
)
@capability(
SourceCapability.LINEAGE_FINE,
"Not supported",
supported=False,
)
class KafkaSource(StatefulIngestionSourceBase, TestableSource):
"""
This plugin extracts the following:

8
metadata-ingestion/src/datahub/ingestion/source/sql/mysql.py
View File

@ -66,6 +66,14 @@ class MySQLConfig(MySQLConnectionConfig, TwoTierSQLAlchemyConfig):
@capability(SourceCapability.DOMAINS, "Supported via the `domain` config field")
@capability(SourceCapability.DATA_PROFILING, "Optionally enabled via configuration")
@capability(SourceCapability.DELETION_DETECTION, "Enabled via stateful ingestion")
@capability(
SourceCapability.LINEAGE_COARSE,
"Supported for views if `include_view_column_lineage` is enabled.",
)
@capability(
SourceCapability.LINEAGE_FINE,
"Supported for views if `include_view_column_lineage` is enabled.",
)
class MySQLSource(TwoTierSQLAlchemySource):
"""
This plugin extracts the following: