10
10
class Application ()
11
11
```
12
12
13
- [[VIEW SOURCE ]](https :// github .com / quixio / quix - streams / blob / main / quixstreams / app .py # L94 )
13
+ [[VIEW SOURCE ]](https :// github .com / quixio / quix - streams / blob / main / quixstreams / app .py # L86 )
14
14
15
15
The main Application class .
16
16
@@ -61,6 +61,7 @@ app.run()
61
61
def __init__ (broker_address: Optional[Union[str , ConnectionConfig]] = None ,
62
62
* ,
63
63
quix_sdk_token: Optional[str ] = None ,
64
+ quix_portal_api: Optional[str ] = None ,
64
65
consumer_group: Optional[str ] = None ,
65
66
auto_offset_reset: AutoOffsetReset = " latest" ,
66
67
commit_interval: float = 5.0 ,
@@ -86,7 +87,7 @@ def __init__(broker_address: Optional[Union[str, ConnectionConfig]] = None,
86
87
max_partition_buffer_size: int = 10000 )
87
88
```
88
89
89
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L132 )
90
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L124 )
90
91
91
92
92
93
< br>
@@ -105,6 +106,11 @@ Either this OR `broker_address` must be set to use Application (not both).
105
106
Linked Environment Variable: `Quix__Sdk__Token` .
106
107
Default: None (if not run on Quix Cloud)
107
108
> *** NOTE :*** the environment variable is set for you in the Quix Cloud
109
+ - `quix_portal_api` : If using the Quix Cloud, the cluster API URL to use.
110
+ Use it to connect to the dedicated Quix Cloud environment.
111
+ Linked Environment Variable: `Quix__Portal__Api` .
112
+ Default: `https:// portal- api.platform.quix.io/ ` .
113
+ > *** NOTE :*** the environment variable is set for you in the Quix Cloud
108
114
- `consumer_group` : Kafka consumer group.
109
115
Passed as `group.id` to `confluent_kafka.Consumer` .
110
116
Linked Environment Variable: `Quix__Consumer_Group` .
0 commit comments