faust.types.settings¶
-
class
faust.types.settings.Settings(id: str, *, debug: bool = None, version: int = None, broker: Union[str, yarl.URL, List[yarl.URL]] = None, broker_client_id: str = None, broker_request_timeout: Union[datetime.timedelta, float, str] = None, broker_credentials: Union[faust.types.auth.CredentialsT, ssl.SSLContext] = None, broker_commit_every: int = None, broker_commit_interval: Union[datetime.timedelta, float, str] = None, broker_commit_livelock_soft_timeout: Union[datetime.timedelta, float, str] = None, broker_session_timeout: Union[datetime.timedelta, float, str] = None, broker_heartbeat_interval: Union[datetime.timedelta, float, str] = None, broker_check_crcs: bool = None, broker_max_poll_records: int = None, broker_max_poll_interval: int = None, broker_consumer: Union[str, yarl.URL, List[yarl.URL]] = None, broker_producer: Union[str, yarl.URL, List[yarl.URL]] = None, agent_supervisor: Union[_T, str] = None, store: Union[str, yarl.URL] = None, cache: Union[str, yarl.URL] = None, web: Union[str, yarl.URL] = None, web_enabled: bool = True, processing_guarantee: Union[str, faust.types.enums.ProcessingGuarantee] = None, timezone: datetime.tzinfo = None, autodiscover: Union[bool, Iterable[str], Callable[Iterable[str]]] = None, origin: str = None, canonical_url: Union[str, yarl.URL] = None, datadir: Union[pathlib.Path, str] = None, tabledir: Union[pathlib.Path, str] = None, key_serializer: Union[faust.types.codecs.CodecT, str, None] = None, value_serializer: Union[faust.types.codecs.CodecT, str, None] = None, logging_config: Dict = None, loghandlers: List[logging.Handler] = None, table_cleanup_interval: Union[datetime.timedelta, float, str] = None, table_standby_replicas: int = None, table_key_index_size: int = None, topic_replication_factor: int = None, topic_partitions: int = None, topic_allow_declare: bool = None, topic_disable_leader: bool = None, id_format: str = None, reply_to: str = None, reply_to_prefix: str = None, reply_create_topic: bool = None, reply_expires: Union[datetime.timedelta, float, str] = None, ssl_context: ssl.SSLContext = None, stream_buffer_maxsize: int = None, stream_wait_empty: bool = None, stream_ack_cancelled_tasks: bool = None, stream_ack_exceptions: bool = None, stream_publish_on_commit: bool = None, stream_recovery_delay: Union[datetime.timedelta, float, str] = None, producer_linger_ms: int = None, producer_max_batch_size: int = None, producer_acks: int = None, producer_max_request_size: int = None, producer_compression_type: str = None, producer_partitioner: Union[_T, str] = None, producer_request_timeout: Union[datetime.timedelta, float, str] = None, producer_api_version: str = None, consumer_max_fetch_size: int = None, consumer_auto_offset_reset: str = None, web_bind: str = None, web_port: int = None, web_host: str = None, web_transport: Union[str, yarl.URL] = None, web_in_thread: bool = None, web_cors_options: Mapping[str, faust.types.web.ResourceOptions] = None, worker_redirect_stdouts: bool = None, worker_redirect_stdouts_level: Union[int, str] = None, Agent: Union[_T, str] = None, ConsumerScheduler: Union[_T, str] = None, Event: Union[_T, str] = None, Schema: Union[_T, str] = None, Stream: Union[_T, str] = None, Table: Union[_T, str] = None, SetTable: Union[_T, str] = None, GlobalTable: Union[_T, str] = None, SetGlobalTable: Union[_T, str] = None, TableManager: Union[_T, str] = None, Serializers: Union[_T, str] = None, Worker: Union[_T, str] = None, PartitionAssignor: Union[_T, str] = None, LeaderAssignor: Union[_T, str] = None, Router: Union[_T, str] = None, Topic: Union[_T, str] = None, HttpClient: Union[_T, str] = None, Monitor: Union[_T, str] = None, url: Union[str, yarl.URL] = None, **kwargs: Any) → None[source]¶ -
-
id_format= '{id}-v{self.version}'¶
-
debug= False¶
-
ssl_context= None¶
-
autodiscover= False¶
-
broker_client_id= 'faust-1.9.0'¶
-
timezone= datetime.timezone.utc¶
-
broker_commit_every= 10000¶
-
broker_check_crcs= True¶
-
broker_max_poll_interval= 1000.0¶
-
key_serializer= 'raw'¶
-
value_serializer= 'json'¶
-
table_standby_replicas= 1¶
-
table_key_index_size= 1000¶
-
topic_replication_factor= 1¶
-
topic_partitions= 8¶
-
topic_allow_declare= True¶
-
topic_disable_leader= False¶
-
reply_create_topic= False¶
-
logging_config= None¶
-
stream_buffer_maxsize= 4096¶
-
stream_wait_empty= True¶
-
stream_ack_cancelled_tasks= True¶
-
stream_ack_exceptions= True¶
-
stream_publish_on_commit= False¶
-
producer_linger_ms= 0¶
-
producer_max_batch_size= 16384¶
-
producer_acks= -1¶
-
producer_max_request_size= 1000000¶
-
producer_compression_type= None¶
-
producer_api_version= 'auto'¶
-
consumer_max_fetch_size= 4194304¶
-
consumer_auto_offset_reset= 'earliest'¶
-
web_bind= '0.0.0.0'¶
-
web_port= 6066¶
-
web_host= 'build-10233069-project-230058-faust'¶
-
web_in_thread= False¶
-
web_cors_options= None¶
-
worker_redirect_stdouts= True¶
-
worker_redirect_stdouts_level= 'WARN'¶
-
reply_to_prefix= 'f-reply-'¶
-
property
processing_guarantee¶ - Return type
-
property
broker_credentials¶ - Return type
-
property
producer_partitioner¶
-
property
agent_supervisor¶ - Return type
-
property
GlobalTable¶ - Return type
Type[GlobalTableT[]]
-
property
SetGlobalTable¶ - Return type
Type[GlobalTableT[]]
-
property
TableManager¶ - Return type
-
property
PartitionAssignor¶ - Return type
-
property
LeaderAssignor¶ - Return type
-
