Merge pull request #2345 from atlanhq/sync-models-20260322-131254

Sync Java SDK models from atlanhq/models

Author: cmgrote

sdk/src/main/java/com/atlan/model/assets/Asset.java

@@ -489,6 +489,14 @@ public abstract class Asset extends Reference implements IAsset, IReferenceable
     @Attribute
     AtlanIcon assetIcon;
 
+    /** The type of request form on Immuta applicable for the asset. */
+    @Attribute
+    String assetImmutaRequestType;
+
+    /** URL of the request form on Immuta relevant to the asset. */
+    @Attribute
+    String assetImmutaRequestUrl;
+
     /** Internal Popularity score for this asset. */
     @Attribute
     Double assetInternalPopularityScore;

sdk/src/main/java/com/atlan/model/assets/AzureEventHub.java

@@ -51,7 +51,7 @@ public class AzureEventHub extends Asset
     @Builder.Default
     String typeName = TYPE_NAME;
 
-    /** TBC */
+    /** Operational status of the Azure Event Hub at the source. */
     @Attribute
     String azureEventHubStatus;
 
@@ -70,23 +70,44 @@ public class AzureEventHub extends Asset
     @Singular
     SortedSet<ISparkJob> inputToSparkJobs;
 
+    /** Kafka cluster containing this topic. */
+    @Attribute
+    IKafkaCluster kafkaCluster;
+
     /** Consumer groups subscribed to this topic. */
     @Attribute
     @Singular
     SortedSet<IKafkaConsumerGroup> kafkaConsumerGroups;
 
+    /** Schema fields defined within this Kafka topic. */
+    @Attribute
+    @Singular
+    SortedSet<IKafkaField> kafkaFields;
+
     /** Cleanup policy for this topic. */
     @Attribute
     KafkaTopicCleanupPolicy kafkaTopicCleanupPolicy;
 
+    /** Unique name of the Kafka cluster in which this topic exists. */
+    @Attribute
+    String kafkaTopicClusterQualifiedName;
+
     /** Type of compression used for this topic. */
     @Attribute
     KafkaTopicCompressionType kafkaTopicCompressionType;
 
+    /** Number of consumer groups consuming this topic. */
+    @Attribute
+    Long kafkaTopicConsumerCount;
+
     /** Whether this topic is an internal topic (true) or not (false). */
     @Attribute
     Boolean kafkaTopicIsInternal;
 
+    /** Whether this topic is fully managed by a schema registry (true) or not (false). */
+    @Attribute
+    Boolean kafkaTopicIsSchemaManaged;
+
     /** Comma seperated Cleanup policy for this topic. */
     @Attribute
     String kafkaTopicLogCleanupPolicy;
@@ -103,10 +124,18 @@ public class AzureEventHub extends Asset
     @Attribute
     Long kafkaTopicReplicationFactor;
 
+    /** Maximum size in bytes that a topic can grow to before discarding old messages; -1 means unlimited. */
+    @Attribute
+    Long kafkaTopicRetentionBytes;
+
     /** Amount of time messages will be retained in this topic, in milliseconds. */
     @Attribute
     Long kafkaTopicRetentionTimeInMs;
 
+    /** Name of the schema registry subject governing this topic, if any. */
+    @Attribute
+    String kafkaTopicSchemaRegistrySubjectName;
+
     /** Segment size for this topic. */
     @Attribute
     Long kafkaTopicSegmentBytes;

sdk/src/main/java/com/atlan/model/assets/AzureEventHubConsumerGroup.java

@@ -9,6 +9,7 @@
 import com.atlan.exception.NotFoundException;
 import com.atlan.model.enums.AtlanAnnouncementType;
 import com.atlan.model.enums.CertificateStatus;
+import com.atlan.model.enums.KafkaConsumerGroupState;
 import com.atlan.model.fields.AtlanField;
 import com.atlan.model.relations.Reference;
 import com.atlan.model.relations.UniqueAttributes;
@@ -73,10 +74,19 @@ public class AzureEventHubConsumerGroup extends Asset
     @Singular
     SortedSet<ISparkJob> inputToSparkJobs;
 
+    /** List of topic-partition pairs assigned to this consumer group. */
+    @Attribute
+    @Singular
+    SortedSet<String> kafkaConsumerGroupAssignedPartitions;
+
     /** Number of members in this consumer group. */
     @Attribute
     Long kafkaConsumerGroupMemberCount;
 
+    /** State of this consumer group. */
+    @Attribute
+    KafkaConsumerGroupState kafkaConsumerGroupState;
+
     /** List of consumption properties for Kafka topics, for this consumer group. */
     @Attribute
     @Singular

sdk/src/main/java/com/atlan/model/assets/IADF.java

@@ -346,6 +346,12 @@ default IApplicationField getApplicationField() {
     /** Name of the icon to use for this asset. (Only applies to glossaries, currently.) */
     AtlanIcon getAssetIcon();
 
+    /** The type of request form on Immuta applicable for the asset. */
+    String getAssetImmutaRequestType();
+
+    /** URL of the request form on Immuta relevant to the asset. */
+    String getAssetImmutaRequestUrl();
+
     /** Internal Popularity score for this asset. */
     Double getAssetInternalPopularityScore();
 

sdk/src/main/java/com/atlan/model/assets/IADLS.java

@@ -352,6 +352,12 @@ default IApplicationField getApplicationField() {
     /** Name of the icon to use for this asset. (Only applies to glossaries, currently.) */
     AtlanIcon getAssetIcon();
 
+    /** The type of request form on Immuta applicable for the asset. */
+    String getAssetImmutaRequestType();
+
+    /** URL of the request form on Immuta relevant to the asset. */
+    String getAssetImmutaRequestUrl();
+
     /** Internal Popularity score for this asset. */
     Double getAssetInternalPopularityScore();
 

sdk/src/main/java/com/atlan/model/assets/IADLSAccount.java

@@ -424,6 +424,12 @@ default IApplicationField getApplicationField() {
     /** Name of the icon to use for this asset. (Only applies to glossaries, currently.) */
     AtlanIcon getAssetIcon();
 
+    /** The type of request form on Immuta applicable for the asset. */
+    String getAssetImmutaRequestType();
+
+    /** URL of the request form on Immuta relevant to the asset. */
+    String getAssetImmutaRequestUrl();
+
     /** Internal Popularity score for this asset. */
     Double getAssetInternalPopularityScore();
 

sdk/src/main/java/com/atlan/model/assets/IADLSContainer.java

@@ -405,6 +405,12 @@ default IApplicationField getApplicationField() {
     /** Name of the icon to use for this asset. (Only applies to glossaries, currently.) */
     AtlanIcon getAssetIcon();
 
+    /** The type of request form on Immuta applicable for the asset. */
+    String getAssetImmutaRequestType();
+
+    /** URL of the request form on Immuta relevant to the asset. */
+    String getAssetImmutaRequestUrl();
+
     /** Internal Popularity score for this asset. */
     Double getAssetInternalPopularityScore();
 

sdk/src/main/java/com/atlan/model/assets/IADLSObject.java

@@ -482,6 +482,12 @@ default IApplicationField getApplicationField() {
     /** Name of the icon to use for this asset. (Only applies to glossaries, currently.) */
     AtlanIcon getAssetIcon();
 
+    /** The type of request form on Immuta applicable for the asset. */
+    String getAssetImmutaRequestType();
+
+    /** URL of the request form on Immuta relevant to the asset. */
+    String getAssetImmutaRequestUrl();
+
     /** Internal Popularity score for this asset. */
     Double getAssetInternalPopularityScore();
 

sdk/src/main/java/com/atlan/model/assets/IAI.java

@@ -367,6 +367,12 @@ default IApplicationField getApplicationField() {
     /** Name of the icon to use for this asset. (Only applies to glossaries, currently.) */
     AtlanIcon getAssetIcon();
 
+    /** The type of request form on Immuta applicable for the asset. */
+    String getAssetImmutaRequestType();
+
+    /** URL of the request form on Immuta relevant to the asset. */
+    String getAssetImmutaRequestUrl();
+
     /** Internal Popularity score for this asset. */
     Double getAssetInternalPopularityScore();
 

sdk/src/main/java/com/atlan/model/assets/IAIApplication.java

@@ -359,6 +359,12 @@ default IApplicationField getApplicationField() {
     /** Name of the icon to use for this asset. (Only applies to glossaries, currently.) */
     AtlanIcon getAssetIcon();
 
+    /** The type of request form on Immuta applicable for the asset. */
+    String getAssetImmutaRequestType();
+
+    /** URL of the request form on Immuta relevant to the asset. */
+    String getAssetImmutaRequestUrl();
+
     /** Internal Popularity score for this asset. */
     Double getAssetInternalPopularityScore();