Page History

package org.apache.kafka.common.audit;
public interface AuditExtension extends Configurable, Closeable {
    /**
     * AuditExtension implementations received an audit event via the {@link
     * #onEvent(AuditEvent)} method. The extension implementation will invoke this method for every audit event occurrence.
     *
     * @param event The audit event we want to describe{@link org.apache.kafka.common.audit.AuditEvent}.
     */
    void onEvent(AuditEvent event);
}