io.confluent.kafka.schemaregistry.id

Class IncrementalIdGenerator

java.lang.Object

io.confluent.kafka.schemaregistry.id.IncrementalIdGenerator

All Implemented Interfaces:

IdGenerator

public class IncrementalIdGenerator
extends Object
implements IdGenerator

Constructor Summary

Constructors

Constructor and Description
IncrementalIdGenerator(SchemaRegistry schemaRegistry)

Method Summary

Modifier and Type	Method and Description
void	configure(SchemaRegistryConfig config) Configure the underlying generator.
int	getMaxId(SchemaValue schema) Returns the current max id from the generator
int	id(SchemaValue schema) Provides the id for the schema.
void	init() Initialize the underlying generator.
void	schemaRegistered(SchemaKey schemaKey, SchemaValue schemaValue) Callback method that is invoked when a schema is registered.

Methods inherited from class java.lang.Object

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

Constructor Detail

IncrementalIdGenerator

public IncrementalIdGenerator(SchemaRegistry schemaRegistry)

Method Detail

id

public int id(SchemaValue schema)
       throws IdGenerationException

Description copied from interface: IdGenerator

Provides the id for the schema.

Specified by:

id in interface IdGenerator

Parameters:

schema - the schema being registered; never null

Returns:

the identifier for the schema; never null

Throws:

IdGenerationException - exception when id can't be generated

getMaxId

public int getMaxId(SchemaValue schema)

Description copied from interface: IdGenerator

Returns the current max id from the generator

Specified by:

getMaxId in interface IdGenerator

Parameters:

schema - current schema in the request to Schema Registry

Returns:

the max id; never null

configure

public void configure(SchemaRegistryConfig config)

Description copied from interface: IdGenerator

Configure the underlying generator.

Specified by:

configure in interface IdGenerator

Parameters:

config - Schema Registry Configs

init

public void init()
          throws IdGenerationException

Description copied from interface: IdGenerator

Initialize the underlying generator.

Specified by:

init in interface IdGenerator

Throws:

IdGenerationException - exception when IdGenerator can't be initialized

schemaRegistered

public void schemaRegistered(SchemaKey schemaKey,
                             SchemaValue schemaValue)

Description copied from interface: IdGenerator

Callback method that is invoked when a schema is registered. IdGenerator implementation can optionally use this to update the next possible id.

Specified by:

schemaRegistered in interface IdGenerator

Parameters:

schemaKey - the registered SchemaKey; never null

schemaValue - the registered SchemaValue; never null