Class DefaultOdysseyRequestManager

java.lang.Object

io.confluent.kafka.odyssey.DefaultOdysseyRequestManager

All Implemented Interfaces:

OdysseyRequestManager, AutoCloseable

public class DefaultOdysseyRequestManager
extends Object
implements OdysseyRequestManager

Constructor Summary

Constructors

Constructor	Description
DefaultOdysseyRequestManager()	Creates a DefaultOdysseyRequestManager with default settings.
DefaultOdysseyRequestManager(int maxThreads, int maxQueueSize, int requestTimeoutMs)	Creates a DefaultOdysseyRequestManager with custom thread pool settings.
DefaultOdysseyRequestManager(int maxThreads, int maxQueueSize, int requestTimeoutMs, Map<String,?> configs)	Creates a DefaultOdysseyRequestManager with custom settings and configuration.

Method Summary

Modifier and Type	Method	Description
void	close()	Gracefully shuts down the manager, cleaning up resources.
CompletableFuture<Map<String, OdysseyResult>>	createAssociations(List<TopicAssociationInfo> topics, boolean topicAlreadyExists, io.confluent.kafka.schemaregistry.client.SchemaRegistryClient client)	Creates associations with Odyssey.
io.confluent.kafka.schemaregistry.client.SchemaRegistryClient	createClient(String schemaRegistryUrl)	Creates a SchemaRegistryClient for the given URL.
CompletableFuture<Map<String, OdysseyResult>>	validate(Map<String, ParsedAssociations> topicAssociations, String namespace, io.confluent.kafka.schemaregistry.client.SchemaRegistryClient client)

Methods inherited from class Object

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

Constructor Details

DefaultOdysseyRequestManager

public DefaultOdysseyRequestManager()

Creates a DefaultOdysseyRequestManager with default settings.

DefaultOdysseyRequestManager

public DefaultOdysseyRequestManager(int maxThreads,
 int maxQueueSize,
 int requestTimeoutMs)

Creates a DefaultOdysseyRequestManager with custom thread pool settings.

Parameters:

maxThreads - maximum number of worker threads

maxQueueSize - maximum queue size for pending requests

requestTimeoutMs - request timeout in milliseconds

DefaultOdysseyRequestManager

public DefaultOdysseyRequestManager(int maxThreads,
 int maxQueueSize,
 int requestTimeoutMs,
 Map<String,?> configs)

Creates a DefaultOdysseyRequestManager with custom settings and configuration.

Parameters:

maxThreads - maximum number of worker threads

maxQueueSize - maximum queue size for pending requests

requestTimeoutMs - request timeout in milliseconds

configs - additional configuration (e.g., authentication for SR clients)

Method Details

createClient

public io.confluent.kafka.schemaregistry.client.SchemaRegistryClient createClient(String schemaRegistryUrl)

Description copied from interface: OdysseyRequestManager

Creates a SchemaRegistryClient for the given URL. The client should be reused for all operations within a single Odyssey request.

Specified by:

createClient in interface OdysseyRequestManager

Parameters:

schemaRegistryUrl - The Schema Registry endpoint URL

Returns:

A configured SchemaRegistryClient (with cacheCapacity=0 for minimal overhead)

validate

public CompletableFuture<Map<String, OdysseyResult>> validate(Map<String, ParsedAssociations> topicAssociations,
 String namespace,
 io.confluent.kafka.schemaregistry.client.SchemaRegistryClient client)

Specified by:

validate in interface OdysseyRequestManager

createAssociations

public CompletableFuture<Map<String, OdysseyResult>> createAssociations(List<TopicAssociationInfo> topics,
 boolean topicAlreadyExists,
 io.confluent.kafka.schemaregistry.client.SchemaRegistryClient client)

Description copied from interface: OdysseyRequestManager

Creates associations with Odyssey.

Specified by:

createAssociations in interface OdysseyRequestManager

Parameters:

topics - List of topics with their association information

topicAlreadyExists - If true, uses INSERT-only semantics (topic already exists)

client - The SchemaRegistryClient

Returns:

CompletableFuture with Map of topic name to result

close

public void close()

Description copied from interface: OdysseyRequestManager

Gracefully shuts down the manager, cleaning up resources.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface OdysseyRequestManager