Class CpcTenantSanitizer

java.lang.Object

io.confluent.kafka.cpc.multitenant.CpcTenantSanitizer

public class CpcTenantSanitizer
extends Object

CPC-only audit-event sanitizer.

Strips the tenant prefix from authorization audit events so they present a tenant-safe view: the resource name (e.g. lkc-xxx_topic) is shown as topic, and the TenantUser principal is shown as a plain User. Only the AUTHORIZATION path is handled; authentication and other event types are out of scope for CPC V1 and pass through unchanged.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CpcTenantSanitizer.NotTenantPrefixedException

Constructor Summary

Constructors

Constructor	Description
CpcTenantSanitizer()

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.server.audit.AuditEvent	cpcTenantAuditEvent(org.apache.kafka.server.audit.AuditEvent auditEvent)	Sanitizer entry point wired via auditLogProvider.setSanitizer(...).

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CpcTenantSanitizer

public CpcTenantSanitizer()

Method Details

cpcTenantAuditEvent

public org.apache.kafka.server.audit.AuditEvent cpcTenantAuditEvent(org.apache.kafka.server.audit.AuditEvent auditEvent)

Sanitizer entry point wired via auditLogProvider.setSanitizer(...).