Skip to content

Streaming & Events

Kafka

pyatlan.model.assets.kafka.Kafka(__pydantic_self__, **data: Any)

Bases: EventStore

Description

Source code in pyatlan/model/assets/core/referenceable.py 
36
37
38
def __init__(__pydantic_self__, **data: Any) -> None:
    super().__init__(**data)
    __pydantic_self__.__fields_set__.update(["attributes", "type_name"])

KafkaTopic

pyatlan.model.assets.kafka_topic.KafkaTopic(__pydantic_self__, **data: Any)

Bases: Kafka

Description

Source code in pyatlan/model/assets/core/referenceable.py 
36
37
38
def __init__(__pydantic_self__, **data: Any) -> None:
    super().__init__(**data)
    __pydantic_self__.__fields_set__.update(["attributes", "type_name"])

Attributes

KAFKA_CONSUMER_GROUPS: RelationField = RelationField('kafkaConsumerGroups') class-attribute

TBC

KAFKA_TOPIC_CLEANUP_POLICY: KeywordField = KeywordField('kafkaTopicCleanupPolicy', 'kafkaTopicCleanupPolicy') class-attribute

Cleanup policy for this topic.

KAFKA_TOPIC_COMPRESSION_TYPE: KeywordField = KeywordField('kafkaTopicCompressionType', 'kafkaTopicCompressionType') class-attribute

Type of compression used for this topic.

KAFKA_TOPIC_IS_INTERNAL: BooleanField = BooleanField('kafkaTopicIsInternal', 'kafkaTopicIsInternal') class-attribute

Whether this topic is an internal topic (true) or not (false).

KAFKA_TOPIC_LOG_CLEANUP_POLICY: KeywordField = KeywordField('kafkaTopicLogCleanupPolicy', 'kafkaTopicLogCleanupPolicy') class-attribute

Comma seperated Cleanup policy for this topic.

KAFKA_TOPIC_PARTITIONS_COUNT: NumericField = NumericField('kafkaTopicPartitionsCount', 'kafkaTopicPartitionsCount') class-attribute

Number of partitions for this topic.

KAFKA_TOPIC_RECORD_COUNT: NumericField = NumericField('kafkaTopicRecordCount', 'kafkaTopicRecordCount') class-attribute

Number of (unexpired) messages in this topic.

KAFKA_TOPIC_REPLICATION_FACTOR: NumericField = NumericField('kafkaTopicReplicationFactor', 'kafkaTopicReplicationFactor') class-attribute

Replication factor for this topic.

KAFKA_TOPIC_RETENTION_TIME_IN_MS: NumericField = NumericField('kafkaTopicRetentionTimeInMs', 'kafkaTopicRetentionTimeInMs') class-attribute

Amount of time messages will be retained in this topic, in milliseconds.

KAFKA_TOPIC_SEGMENT_BYTES: NumericField = NumericField('kafkaTopicSegmentBytes', 'kafkaTopicSegmentBytes') class-attribute

Segment size for this topic.

KAFKA_TOPIC_SIZE_IN_BYTES: NumericField = NumericField('kafkaTopicSizeInBytes', 'kafkaTopicSizeInBytes') class-attribute

Size of this topic, in bytes.

KafkaConsumerGroup

pyatlan.model.assets.kafka_consumer_group.KafkaConsumerGroup(__pydantic_self__, **data: Any)

Bases: Kafka

Description

Source code in pyatlan/model/assets/core/referenceable.py 
36
37
38
def __init__(__pydantic_self__, **data: Any) -> None:
    super().__init__(**data)
    __pydantic_self__.__fields_set__.update(["attributes", "type_name"])

Attributes

KAFKA_CONSUMER_GROUP_MEMBER_COUNT: NumericField = NumericField('kafkaConsumerGroupMemberCount', 'kafkaConsumerGroupMemberCount') class-attribute

Number of members in this consumer group.

KAFKA_CONSUMER_GROUP_TOPIC_CONSUMPTION_PROPERTIES: KeywordField = KeywordField('kafkaConsumerGroupTopicConsumptionProperties', 'kafkaConsumerGroupTopicConsumptionProperties') class-attribute

List of consumption properties for Kafka topics, for this consumer group.

KAFKA_TOPICS: RelationField = RelationField('kafkaTopics') class-attribute

TBC

KAFKA_TOPIC_NAMES: KeywordField = KeywordField('kafkaTopicNames', 'kafkaTopicNames') class-attribute

Simple names of the topics consumed by this consumer group.

KAFKA_TOPIC_QUALIFIED_NAMES: KeywordField = KeywordField('kafkaTopicQualifiedNames', 'kafkaTopicQualifiedNames') class-attribute

Unique names of the topics consumed by this consumer group.

AzureServiceBus

pyatlan.model.assets.azure_service_bus.AzureServiceBus(__pydantic_self__, **data: Any)

Bases: EventStore

Description

Source code in pyatlan/model/assets/core/referenceable.py 
36
37
38
def __init__(__pydantic_self__, **data: Any) -> None:
    super().__init__(**data)
    __pydantic_self__.__fields_set__.update(["attributes", "type_name"])

Attributes

AZURE_SERVICE_BUS_NAMESPACE_NAME: KeywordTextField = KeywordTextField('azureServiceBusNamespaceName', 'azureServiceBusNamespaceName.keyword', 'azureServiceBusNamespaceName') class-attribute

Simple name of the AzureServiceBus Namespace in which this asset exists.

AZURE_SERVICE_BUS_NAMESPACE_QUALIFIED_NAME: KeywordField = KeywordField('azureServiceBusNamespaceQualifiedName', 'azureServiceBusNamespaceQualifiedName') class-attribute

Unique name of the AzureServiceBus Namespace in which this asset exists.

AZURE_SERVICE_BUS_SCHEMA_QUALIFIED_NAME: KeywordField = KeywordField('azureServiceBusSchemaQualifiedName', 'azureServiceBusSchemaQualifiedName') class-attribute

Unique name of the AzureServiceBus Schema in which this asset exists.

AzureServiceBusNamespace

pyatlan.model.assets.azure_service_bus_namespace.AzureServiceBusNamespace(__pydantic_self__, **data: Any)

Bases: AzureServiceBus

Description

Source code in pyatlan/model/assets/core/referenceable.py 
36
37
38
def __init__(__pydantic_self__, **data: Any) -> None:
    super().__init__(**data)
    __pydantic_self__.__fields_set__.update(["attributes", "type_name"])

Attributes

AZURE_SERVICE_BUS_TOPICS: RelationField = RelationField('azureServiceBusTopics') class-attribute

TBC

AzureServiceBusSchema

pyatlan.model.assets.azure_service_bus_schema.AzureServiceBusSchema(__pydantic_self__, **data: Any)

Bases: AzureServiceBus

Description

Source code in pyatlan/model/assets/core/referenceable.py 
36
37
38
def __init__(__pydantic_self__, **data: Any) -> None:
    super().__init__(**data)
    __pydantic_self__.__fields_set__.update(["attributes", "type_name"])

Attributes

AZURE_SERVICE_BUS_TOPICS: RelationField = RelationField('azureServiceBusTopics') class-attribute

TBC

AzureServiceBusTopic

pyatlan.model.assets.azure_service_bus_topic.AzureServiceBusTopic(__pydantic_self__, **data: Any)

Bases: AzureServiceBus

Description

Source code in pyatlan/model/assets/core/referenceable.py 
36
37
38
def __init__(__pydantic_self__, **data: Any) -> None:
    super().__init__(**data)
    __pydantic_self__.__fields_set__.update(["attributes", "type_name"])

Attributes

AZURE_SERVICE_BUS_NAMESPACE: RelationField = RelationField('azureServiceBusNamespace') class-attribute

TBC

AZURE_SERVICE_BUS_SCHEMAS: RelationField = RelationField('azureServiceBusSchemas') class-attribute

TBC

AzureEventHub

pyatlan.model.assets.azure_event_hub.AzureEventHub(__pydantic_self__, **data: Any)

Bases: KafkaTopic

Description

Source code in pyatlan/model/assets/core/referenceable.py 
36
37
38
def __init__(__pydantic_self__, **data: Any) -> None:
    super().__init__(**data)
    __pydantic_self__.__fields_set__.update(["attributes", "type_name"])

Attributes

AZURE_EVENT_HUB_STATUS: KeywordField = KeywordField('azureEventHubStatus', 'azureEventHubStatus') class-attribute

AzureEventHubConsumerGroup

pyatlan.model.assets.azure_event_hub_consumer_group.AzureEventHubConsumerGroup(__pydantic_self__, **data: Any)

Bases: KafkaConsumerGroup

Description

Source code in pyatlan/model/assets/core/referenceable.py 
36
37
38
def __init__(__pydantic_self__, **data: Any) -> None:
    super().__init__(**data)
    __pydantic_self__.__fields_set__.update(["attributes", "type_name"])

EventStore

pyatlan.model.assets.event_store.EventStore(__pydantic_self__, **data: Any)

Bases: Catalog

Description

Source code in pyatlan/model/assets/core/referenceable.py 
36
37
38
def __init__(__pydantic_self__, **data: Any) -> None:
    super().__init__(**data)
    __pydantic_self__.__fields_set__.update(["attributes", "type_name"])