feat: Add Kafka topic support

Author: sbernauer

rust/resource-info-fetcher/src/api.rs

@@ -48,6 +48,11 @@ pub enum ResourceInfoRequestResource {
     SupersetDashboard {
         id: u64,
     },
+
+    KafkaTopic {
+        topic: String,
+    },
+
     RawDataHubUrn(String),
 }
 

rust/resource-info-fetcher/src/backend/data_hub/mod.rs

@@ -110,6 +110,7 @@ pub struct ResolvedDataHubBackend {
 #[derive(Debug, Clone, PartialEq, Eq, Hash, Serialize)]
 #[serde(rename_all = "camelCase")]
 pub struct DataHubResourceInfoResponse {
+    urn: Urn,
     owners: BTreeMap<OwnerType, DataHubResourceInfoResponseOwners>,
     tags: Vec<Tag>,
 }
@@ -271,6 +272,7 @@ impl ResourceInfoBackend for ResolvedDataHubBackend {
         let (tags, owners) = futures::try_join!(tags_fut, owners_fut)?;
 
         Ok(DataHubResourceInfoResponse {
+            urn,
             tags,
             owners: owners.into_iter().collect(),
         })

rust/resource-info-fetcher/src/backend/data_hub/resource_to_urn_mapping.rs

@@ -39,6 +39,9 @@ pub fn urn_for_request(request: &ResourceInfoRequest, env: &str) -> Urn {
         ResourceInfoRequestResource::SupersetDashboard { id } => {
             format!("urn:li:dashboard:({stacklet},{id})")
         }
+        ResourceInfoRequestResource::KafkaTopic { topic } => {
+            format!("urn:li:dataset:(urn:li:dataPlatform:{stacklet},{topic},{env})")
+        }
         ResourceInfoRequestResource::RawDataHubUrn(urn) => urn.to_owned(),
     };