ractogateway.kafka.audit

Immutable prompt/response audit logging over Kafka.

class ractogateway.kafka.audit.KafkaAuditLogger(producer, *, topic='ractogateway.audit')

Bases: object

Asynchronous audit logger for regulated AI workloads.

Writes immutable prompt/response records to a dedicated Kafka topic so audit traces survive web-process crashes and can be replayed later.

property topic: str

log(*, user_id, model, prompt, response, request_id=None, metadata=None, wait=False)

Publish one immutable audit record.

Parameters:

wait (bool) – If True, block until Kafka acknowledges the write. For high-throughput request paths, False is usually preferred.

Return type:

KafkaAuditEvent