io.confluent.security.audit.router

Class AuditLogRouterJsonConfig

java.lang.Object

io.confluent.security.audit.router.AuditLogRouterJsonConfig

public class AuditLogRouterJsonConfig
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AuditLogRouterJsonConfig.Canonicalizer Renames any legacy "other" category rule to a "management" rule, or drops the "other" category rule if both are present.
static class	AuditLogRouterJsonConfig.DefaultTopics
static class	AuditLogRouterJsonConfig.Destinations
static class	AuditLogRouterJsonConfig.DestinationTopic
static class	AuditLogRouterJsonConfig.Metadata

Field Summary

Fields

Modifier and Type	Field and Description
static Map<String,AuditLogRouterResult>	ALLOWED_RESULTS
static long	DEFAULT_RETENTION_MS
static String	DEFAULT_TOPIC
static String	DEFAULT_V2_TOPIC
static Optional<String>	DEFAULT_V2_TOPIC_ROUTE
AuditLogRouterJsonConfig.DefaultTopics	defaultTopics
AuditLogRouterJsonConfig.Destinations	destinations
List<String>	excludedPrincipals
AuditLogRouterJsonConfig.Metadata	metadata
Map<String,Map<String,Map<String,String>>>	routes
static String	TOPIC_PREFIX

Constructor Summary

Constructors

Constructor and Description
AuditLogRouterJsonConfig()

Method Summary

Modifier and Type	Method and Description
String	bootstrapServers()
static AuditLogRouterJsonConfig	defaultConfig() This config is used if the AuditLogging feature is not configured.
static AuditLogRouterJsonConfig	load(String json) Throws IllegalArgumentException if the config is Invalid
static AuditLogRouterResult	result(String resultName)
String	toJsonString()
static void	validate(AuditLogRouterJsonConfig config)
static void	validateDefaultTopics(AuditLogRouterJsonConfig config, Set<String> allowedTopics)
static void	validateRoutes(AuditLogRouterJsonConfig config, Set<String> allowedTopics)

Methods inherited from class java.lang.Object

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

Field Detail

ALLOWED_RESULTS

public static final Map<String,AuditLogRouterResult> ALLOWED_RESULTS

TOPIC_PREFIX

public static final String TOPIC_PREFIX

See Also:

Constant Field Values

DEFAULT_TOPIC

public static final String DEFAULT_TOPIC

See Also:

Constant Field Values

DEFAULT_V2_TOPIC

public static final String DEFAULT_V2_TOPIC

See Also:

Constant Field Values

DEFAULT_V2_TOPIC_ROUTE

public static final Optional<String> DEFAULT_V2_TOPIC_ROUTE

DEFAULT_RETENTION_MS

public static final long DEFAULT_RETENTION_MS

See Also:

Constant Field Values

defaultTopics

public AuditLogRouterJsonConfig.DefaultTopics defaultTopics

excludedPrincipals

public List<String> excludedPrincipals

routes

public Map<String,Map<String,Map<String,String>>> routes

metadata

public AuditLogRouterJsonConfig.Metadata metadata

destinations

public AuditLogRouterJsonConfig.Destinations destinations

Constructor Detail

AuditLogRouterJsonConfig

public AuditLogRouterJsonConfig()

Method Detail

validateDefaultTopics

public static void validateDefaultTopics(AuditLogRouterJsonConfig config,
                                         Set<String> allowedTopics)

validateRoutes

public static void validateRoutes(AuditLogRouterJsonConfig config,
                                  Set<String> allowedTopics)

validate

public static void validate(AuditLogRouterJsonConfig config)

result

public static AuditLogRouterResult result(String resultName)

load

public static AuditLogRouterJsonConfig load(String json)
                                     throws IOException

Throws IllegalArgumentException if the config is Invalid

Throws:

IOException

bootstrapServers

public String bootstrapServers()

defaultConfig

public static AuditLogRouterJsonConfig defaultConfig()

This config is used if the AuditLogging feature is not configured. It sends audit logging messages to the local cluster via the interbroker listener.

toJsonString

public String toJsonString()
                    throws com.fasterxml.jackson.core.JsonProcessingException

Throws:

com.fasterxml.jackson.core.JsonProcessingException