@@ -6230,7 +6230,7 @@ def topic(name: str,
62306230 timestamp_extractor: Optional[TimestampExtractor] = None) -> Topic
62316231```
62326232
6233- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/models/topics/manager.py#L254 )
6233+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/models/topics/manager.py#L255 )
62346234
62356235A convenience method for generating a `Topic`. Will use default config options
62366236
@@ -6259,7 +6259,7 @@ Topic object with creation configs
62596259def register(topic: Topic) -> Topic
62606260```
62616261
6262- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/models/topics/manager.py#L300 )
6262+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/models/topics/manager.py#L301 )
62636263
62646264Register an already generated :class:`quixstreams.models.topics.Topic` to the topic manager.
62656265
@@ -6283,7 +6283,7 @@ def repartition_topic(operation: str,
62836283 timeout: Optional[float] = None) -> Topic
62846284```
62856285
6286- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/models/topics/manager.py#L318 )
6286+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/models/topics/manager.py#L319 )
62876287
62886288Create an internal repartition topic.
62896289
@@ -6312,7 +6312,7 @@ def changelog_topic(topic_name: Optional[str],
63126312 timeout: Optional[float] = None) -> Topic
63136313```
63146314
6315- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/models/topics/manager.py#L358 )
6315+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/models/topics/manager.py#L359 )
63166316
63176317Performs all the logic necessary to generate a changelog topic based on an
63186318
@@ -6354,7 +6354,7 @@ def create_topics(topics: List[Topic],
63546354 create_timeout: Optional[float] = None)
63556355```
63566356
6357- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/models/topics/manager.py#L426 )
6357+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/models/topics/manager.py#L428 )
63586358
63596359Creates topics via an explicit list of provided `Topics`.
63606360
@@ -6376,7 +6376,7 @@ def create_all_topics(timeout: Optional[float] = None,
63766376 create_timeout: Optional[float] = None)
63776377```
63786378
6379- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/models/topics/manager.py#L454 )
6379+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/models/topics/manager.py#L456 )
63806380
63816381A convenience method to create all Topic objects stored on this TopicManager.
63826382
@@ -6395,7 +6395,7 @@ If `auto_create_topics` is set to False no topic will be created.
63956395def validate_all_topics(timeout: Optional[float] = None)
63966396```
63976397
6398- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/models/topics/manager.py#L470 )
6398+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/models/topics/manager.py#L472 )
63996399
64006400Validates all topics exist and changelogs have correct topic and rep factor.
64016401
0 commit comments