Decorators

kafkastreamer.register(model: type[Model], streamer_class: type[Streamer] | None = None, set_handlers: bool = True, **kwargs: Any) → Any

Registers Django model using the given streamer class. It may be used as a plain function call or as decorator on streamer class.

kafkastreamer.admin_site(source: str) → Callable[[type[AdminSite]], type[AdminSite]]

Decorator function for model admin site class to set streamer context and squashing.