faust.types.settings
¶
-
class
faust.types.settings.
Settings
(id: str, *, 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_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, 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, 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, loghandlers: List[logging.Handler] = None, table_cleanup_interval: Union[datetime.timedelta, float, str] = None, table_standby_replicas: int = None, topic_replication_factor: int = None, topic_partitions: int = 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, consumer_max_fetch_size: int = None, web_bind: str = None, web_port: int = None, web_host: str = None, web_transport: Union[str, yarl.URL] = None, worker_redirect_stdouts: bool = None, worker_redirect_stdouts_level: Union[int, str] = None, Agent: Union[_T, str] = None, Stream: Union[_T, str] = None, Table: Union[_T, str] = None, SetTable: 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) → None[source]¶ -
-
id_format
= '{id}-v{self.version}'¶
-
ssl_context
= None¶
-
autodiscover
= False¶
-
broker_client_id
= 'faust-1.4.6'¶
-
timezone
= datetime.timezone.utc¶
-
broker_commit_every
= 10000¶
-
broker_check_crcs
= True¶
-
key_serializer
= 'raw'¶
-
value_serializer
= 'json'¶
-
table_standby_replicas
= 1¶
-
topic_replication_factor
= 1¶
-
topic_partitions
= 8¶
-
reply_create_topic
= False¶
-
stream_buffer_maxsize
= 4096¶
-
stream_wait_empty
= True¶
-
stream_ack_cancelled_tasks
= False¶
-
stream_ack_exceptions
= True¶
-
stream_publish_on_commit
= False¶
-
producer_linger_ms
= 0¶
-
producer_max_batch_size
= 4096¶
-
producer_acks
= -1¶
-
producer_max_request_size
= 1000000¶
-
producer_compression_type
= None¶
-
consumer_max_fetch_size
= 4194304¶
-
web_bind
= '0.0.0.0'¶
-
web_port
= 6066¶
-
web_host
= 'build-8661279-project-230058-faust'¶
-
worker_redirect_stdouts
= True¶
-
worker_redirect_stdouts_level
= 'WARN'¶
-
reply_to_prefix
= 'f-reply-'¶
-
producer_partitioner
¶ Return type: Optional
[Callable
[[Optional
[bytes
],Sequence
[int
],Sequence
[int
]],int
]]
-
agent_supervisor
¶ Return type: Type
[SupervisorStrategyT
]
-
TableManager
¶ Return type: Type
[TableManagerT
[]]
-
PartitionAssignor
¶ Return type: Type
[PartitionAssignorT
]
-
LeaderAssignor
¶ Return type: Type
[LeaderAssignorT
[]]
-