fraudtwin.KafkaChaosConfig#

class fraudtwin.KafkaChaosConfig(**data)[source][source]#

Bases: BaseModel

Immutable, seeded policy for logical Kafka delivery faults.

Parameters:

  • seed (int)

  • boundary (Literal['producer', 'consumer'])

  • drop_probability (float)

  • duplicate_probability (float)

  • retry_probability (float)

  • max_delay_seconds (int)

  • reorder_window (int)

  • partition_count (int)

  • partition_skew_probability (float)

  • outages (tuple[KafkaChaosOutage, ...])

model_config: ClassVar[ConfigDict] = {'extra': 'forbid', 'frozen': True}#

Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].