Constant Field Values

io.confluent.*

io.confluent.kafka.odyssey.OdysseyConstants.ConfigKeys

Modifier and Type	Constant Field	Value
public static final String	KEY_ASSOCIATION_CONFIG	"confluent.key.association"
public static final String	KEY_ASSOCIATION_DOC	"JSON payload for key schema association (subject, lifecycle, schemaType, schema, metadata, ruleSet, references)"
public static final String	TYPE_KEY	"key"
public static final String	TYPE_VALUE	"value"
public static final String	VALUE_ASSOCIATION_CONFIG	"confluent.value.association"
public static final String	VALUE_ASSOCIATION_DOC	"JSON payload for value schema association (subject, lifecycle, schemaType, schema, metadata, ruleSet, references)"

io.confluent.kafka.odyssey.OdysseyConstants.Defaults

Modifier and Type	Constant Field	Value
public static final String	LIFECYCLE_STRONG	"STRONG"
public static final String	LIFECYCLE_WEAK	"WEAK"
public static final int	MAX_QUEUE_SIZE	1000
public static final int	MAX_THREADS	10
public static final long	QUEUE_WARNING_INTERVAL_MS	60000L
public static final double	QUEUE_WARNING_THRESHOLD	75.0
public static final int	REQUEST_TIMEOUT_MS	30000
public static final String	RESOURCE_TYPE_TOPIC	"topic"
public static final String	SCHEMA_TYPE_AVRO	"AVRO"
public static final long	THREAD_IDLE_TIMEOUT_SECONDS	60L

io.confluent.kafka.odyssey.OdysseyConstants.ErrorCodes

Modifier and Type	Constant Field	Value
public static final int	ASSOCIATION_CREATION_FAILED	50003
public static final int	ODYSSEY_ERROR	50001
public static final int	ODYSSEY_SR_UNAVAILABLE	50002
public static final int	SCHEMA_VALIDATION_ERROR	42201

io.confluent.kafka.odyssey.OdysseyConstants.ErrorMessages

Modifier and Type	Constant Field	Value
public static final String	FAILED_TO_PARSE_RESPONSE	"Failed to parse response: %s"
public static final String	INVALID_207_RESPONSE	"Invalid HTTP 207 response format"
public static final String	MISSING_REQUIRED_CONFIG	"Missing required config: %s"
public static final String	ODYSSEY_OVERLOADED	"Schema validation service is temporarily overloaded. Please retry after sometime"
public static final String	ODYSSEY_SERVICE_ERROR	"Odyssey service error: %s"
public static final String	ODYSSEY_TIMEOUT	"Odyssey timeout: %s"
public static final String	UNEXPECTED_ERROR	"Unexpected error: %s"

io.confluent.kafka.odyssey.auth.TokenPlatformClientConfig

Modifier and Type	Constant Field	Value
public static final int	DEFAULT_MAX_RETRIES	3
public static final int	DEFAULT_REQUEST_TIMEOUT_MS	5000

io.confluent.kafka.odyssey.auth.TokenPlatformClientFactory

Modifier and Type	Constant Field	Value
public static final String	LOCAL_DEV_SENTINEL	"local://"