@@ -504,6 +504,7 @@ def get_consumer(auto_commit_enable: bool = True) -> Consumer
504
504
[[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L692)
505
505
506
506
Create and return a pre- configured Consumer instance.
507
+
507
508
The Consumer is initialized with params passed to Application.
508
509
509
510
It' s useful for consuming data from Kafka outside the standard
@@ -523,6 +524,13 @@ the consumer config when creating the app.
523
524
< br>
524
525
** * Example Snippet:***
525
526
527
+
528
+
529
+ < br>
530
+ ** * Arguments:***
531
+
532
+ - `auto_commit_enable` : Enable or disable auto commit
533
+ Default - True
526
534
```python
527
535
from quixstreams import Application
528
536
@@ -550,7 +558,7 @@ with app.get_consumer() as consumer:
550
558
def clear_state()
551
559
```
552
560
553
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L739 )
561
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L742 )
554
562
555
563
Clear the state of the application.
556
564
@@ -564,7 +572,7 @@ Clear the state of the application.
564
572
def add_source(source: BaseSource, topic: Optional[Topic] = None ) -> Topic
565
573
```
566
574
567
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L745 )
575
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L748 )
568
576
569
577
Add a source to the application.
570
578
@@ -588,7 +596,7 @@ Default: the source default
588
596
def run(dataframe: StreamingDataFrame)
589
597
```
590
598
591
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L764 )
599
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L767 )
592
600
593
601
Start processing data from Kafka using provided `StreamingDataFrame`
594
602
@@ -620,6 +628,20 @@ app.run(dataframe=df)
620
628
621
629
- `dataframe` : instance of `StreamingDataFrame`
622
630
631
+ < a id = " quixstreams.app.Application.setup_topics" >< / a>
632
+
633
+ < br>< br>
634
+
635
+ # ### Application.setup\_topics
636
+
637
+ ```python
638
+ def setup_topics()
639
+ ```
640
+
641
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L887)
642
+
643
+ Validate and create the topics
644
+
623
645
< a id = " quixstreams.app.ApplicationConfig" >< / a>
624
646
625
647
# ## ApplicationConfig
@@ -628,7 +650,7 @@ app.run(dataframe=df)
628
650
class ApplicationConfig(BaseSettings)
629
651
```
630
652
631
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L1056 )
653
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L1063 )
632
654
633
655
Immutable object holding the application configuration
634
656
@@ -651,7 +673,7 @@ def settings_customise_sources(
651
673
) -> Tuple[PydanticBaseSettingsSource, ... ]
652
674
```
653
675
654
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L1090 )
676
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L1097 )
655
677
656
678
Included to ignore reading/ setting values from the environment
657
679
@@ -665,7 +687,7 @@ Included to ignore reading/setting values from the environment
665
687
def copy(** kwargs) -> Self
666
688
```
667
689
668
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L1103 )
690
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L1110 )
669
691
670
692
Update the application config and return a copy
671
693
0 commit comments