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	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 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.ErrorMessages

Modifier and Type	Constant Field	Value
public static final String	FAILED_TO_PARSE_RESPONSE	"Failed to parse response: %s"
public static final String	GENERIC_UNEXPECTED_ERROR	"Schema registry unexpected error."
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_TIMEOUT	"Odyssey timeout: %s"
public static final String	ORPHAN_REMEDIATION	"Topic was created but its schema association was not registered. Delete the topic and retry, or register the association on the existing topic via incremental alter configs."
public static final String	TOPIC_ID_NOT_FOUND	"Topic ID not found for topic \'%s\'"
public static final String	UNEXPECTED_ERROR	"Unexpected error: %s"

io.confluent.kafka.odyssey.OdysseyConstants.Metrics

Modifier and Type	Constant Field	Value
public static final String	JMX_DOMAIN_SCHEMA_MANAGEMENT	"io.confluent.kafka.schema-management"

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