10
10
class Application ()
11
11
```
12
12
13
- [[VIEW SOURCE ]](https :// github .com / quixio / quix - streams / blob / main / quixstreams / app .py # L79 )
13
+ [[VIEW SOURCE ]](https :// github .com / quixio / quix - streams / blob / main / quixstreams / app .py # L80 )
14
14
15
15
The main Application class .
16
16
@@ -85,7 +85,7 @@ def __init__(broker_address: Optional[Union[str, ConnectionConfig]] = None,
85
85
processing_guarantee: ProcessingGuarantee = " at-least-once" )
86
86
```
87
87
88
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L117 )
88
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L118 )
89
89
90
90
91
91
< br>
@@ -174,7 +174,7 @@ instead of the default one.
174
174
def Quix(cls , * args, ** kwargs)
175
175
```
176
176
177
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L361 )
177
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L364 )
178
178
179
179
RAISES EXCEPTION : DEPRECATED .
180
180
@@ -197,7 +197,7 @@ def topic(name: str,
197
197
timestamp_extractor: Optional[TimestampExtractor] = None ) -> Topic
198
198
```
199
199
200
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L393 )
200
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L396 )
201
201
202
202
Create a topic definition.
203
203
@@ -279,7 +279,7 @@ def dataframe(topic: Optional[Topic] = None,
279
279
source: Optional[BaseSource] = None ) -> StreamingDataFrame
280
280
```
281
281
282
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L473 )
282
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L476 )
283
283
284
284
A simple helper method that generates a `StreamingDataFrame` , which is used
285
285
@@ -335,7 +335,7 @@ to be used as an input topic.
335
335
def stop(fail: bool = False )
336
336
```
337
337
338
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L529 )
338
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L532 )
339
339
340
340
Stop the internal poll loop and the message processing.
341
341
@@ -362,7 +362,7 @@ to unhandled exception, and it shouldn't commit the current checkpoint.
362
362
def get_producer() -> Producer
363
363
```
364
364
365
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L574 )
365
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L577 )
366
366
367
367
Create and return a pre- configured Producer instance.
368
368
The Producer is initialized with params passed to Application.
@@ -397,7 +397,7 @@ with app.get_producer() as producer:
397
397
def get_consumer(auto_commit_enable: bool = True ) -> Consumer
398
398
```
399
399
400
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L629 )
400
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L632 )
401
401
402
402
Create and return a pre- configured Consumer instance.
403
403
@@ -454,7 +454,7 @@ with app.get_consumer() as consumer:
454
454
def clear_state()
455
455
```
456
456
457
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L679 )
457
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L682 )
458
458
459
459
Clear the state of the application.
460
460
@@ -468,7 +468,7 @@ Clear the state of the application.
468
468
def add_source(source: BaseSource, topic: Optional[Topic] = None ) -> Topic
469
469
```
470
470
471
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L685 )
471
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L688 )
472
472
473
473
Add a source to the application.
474
474
@@ -495,7 +495,7 @@ Note: the names of default topics are prefixed with "source__".
495
495
def run(dataframe: Optional[StreamingDataFrame] = None )
496
496
```
497
497
498
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L718 )
498
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L721 )
499
499
500
500
Start processing data from Kafka using provided `StreamingDataFrame`
501
501
@@ -531,7 +531,7 @@ app.run()
531
531
def setup_topics()
532
532
```
533
533
534
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L843 )
534
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L846 )
535
535
536
536
Validate the application topics
537
537
@@ -543,7 +543,7 @@ Validate the application topics
543
543
class ApplicationConfig(BaseSettings)
544
544
```
545
545
546
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L1025 )
546
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L1014 )
547
547
548
548
Immutable object holding the application configuration
549
549
@@ -566,7 +566,7 @@ def settings_customise_sources(
566
566
) -> Tuple[PydanticBaseSettingsSource, ... ]
567
567
```
568
568
569
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L1060 )
569
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L1049 )
570
570
571
571
Included to ignore reading/ setting values from the environment
572
572
@@ -580,7 +580,7 @@ Included to ignore reading/setting values from the environment
580
580
def copy(** kwargs) -> Self
581
581
```
582
582
583
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L1073 )
583
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L1062 )
584
584
585
585
Update the application config and return a copy
586
586
0 commit comments