KafkaTopic#
- class pyatlan.model.assets.KafkaTopic(*, typeName: str = 'KafkaTopic', attributes: KafkaTopic.Attributes = None, businessAttributes: Dict[str, Any] | None = None, createdBy: str | None = None, createTime: int | None = None, deleteHandler: str | None = None, guid: str = '', isIncomplete: bool | None = True, labels: List[str] | None = None, relationshipAttributes: Dict[str, Any] | None = None, status: EntityStatus | None = None, updatedBy: str | None = None, updateTime: int | None = None, version: int | None = None, classifications: List[AtlanTag] | None = None, classificationNames: List[str] | None = None, displayText: str | None = None, entityStatus: str | None = None, relationshipGuid: str | None = None, relationshipStatus: str | None = None, relationshipType: str | None = None, meaningNames: List[str] | None = None, meanings: List[Meaning] | None = None, customAttributes: Dict[str, Any] | None = None, scrubbed: bool | None = None, pendingTasks: List[str] | None = None, uniqueAttributes: Dict[str, Any] | None = None, appendRelationshipAttributes: Dict[str, Any] | None = None, removeRelationshipAttributes: Dict[str, Any] | None = None, semantic: SaveSemantic | None = None, depth: int | None = None)[source]#
Description
- KAFKA_CONSUMER_GROUPS: ClassVar[RelationField] = <pyatlan.model.fields.atlan_fields.RelationField object>#
TBC
- KAFKA_TOPIC_CLEANUP_POLICY: ClassVar[KeywordField] = <pyatlan.model.fields.atlan_fields.KeywordField object>#
Cleanup policy for this topic.
- KAFKA_TOPIC_COMPRESSION_TYPE: ClassVar[KeywordField] = <pyatlan.model.fields.atlan_fields.KeywordField object>#
Type of compression used for this topic.
- KAFKA_TOPIC_IS_INTERNAL: ClassVar[BooleanField] = <pyatlan.model.fields.atlan_fields.BooleanField object>#
Whether this topic is an internal topic (true) or not (false).
- KAFKA_TOPIC_PARTITIONS_COUNT: ClassVar[NumericField] = <pyatlan.model.fields.atlan_fields.NumericField object>#
Number of partitions for this topic.
- KAFKA_TOPIC_RECORD_COUNT: ClassVar[NumericField] = <pyatlan.model.fields.atlan_fields.NumericField object>#
Number of (unexpired) messages in this topic.
- KAFKA_TOPIC_REPLICATION_FACTOR: ClassVar[NumericField] = <pyatlan.model.fields.atlan_fields.NumericField object>#
Replication factor for this topic.
- KAFKA_TOPIC_RETENTION_TIME_IN_MS: ClassVar[NumericField] = <pyatlan.model.fields.atlan_fields.NumericField object>#
Amount of time messages will be retained in this topic, in milliseconds.
- KAFKA_TOPIC_SEGMENT_BYTES: ClassVar[NumericField] = <pyatlan.model.fields.atlan_fields.NumericField object>#
Segment size for this topic.
- KAFKA_TOPIC_SIZE_IN_BYTES: ClassVar[NumericField] = <pyatlan.model.fields.atlan_fields.NumericField object>#
Size of this topic, in bytes.