io.confluent.kafka.schemaregistry.storage

Class SchemaRegistryIdentity

java.lang.Object

io.confluent.kafka.schemaregistry.storage.SchemaRegistryIdentity

public class SchemaRegistryIdentity
extends Object

The identity of a schema registry instance.

Field Summary

Fields

Modifier and Type	Field and Description
static int	CURRENT_VERSION

Constructor Summary

Constructors

Constructor and Description
SchemaRegistryIdentity(String host, Integer port, Boolean leaderEligibility, String scheme)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
static SchemaRegistryIdentity	fromJson(ByteBuffer json)
static SchemaRegistryIdentity	fromJson(String json)
static int	getCurrentVersion()
String	getHost()
boolean	getLeaderEligibility()
Integer	getPort()
String	getScheme()
String	getUrl()
Integer	getVersion()
int	hashCode()
Boolean	isLeader()
void	setHost(String host)
void	setLeader(Boolean isLeader)
void	setLeaderEligibility(Boolean eligibility)
void	setPort(Integer port)
void	setScheme(String scheme)
void	setVersion(Integer version)
String	toJson()
ByteBuffer	toJsonBytes()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

CURRENT_VERSION

public static final int CURRENT_VERSION

See Also:

Constant Field Values

Constructor Detail

SchemaRegistryIdentity

public SchemaRegistryIdentity(String host,
                              Integer port,
                              Boolean leaderEligibility,
                              String scheme)

Method Detail

fromJson

public static SchemaRegistryIdentity fromJson(String json)
                                       throws IOException

Throws:

IOException

fromJson

public static SchemaRegistryIdentity fromJson(ByteBuffer json)

getVersion

public Integer getVersion()

setVersion

public void setVersion(Integer version)

getHost

public String getHost()

setHost

public void setHost(String host)

getPort

public Integer getPort()

setPort

public void setPort(Integer port)

getLeaderEligibility

public boolean getLeaderEligibility()

setLeaderEligibility

public void setLeaderEligibility(Boolean eligibility)

getScheme

public String getScheme()

setScheme

public void setScheme(String scheme)

getCurrentVersion

public static int getCurrentVersion()

isLeader

public Boolean isLeader()

setLeader

public void setLeader(Boolean isLeader)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

toJson

public String toJson()
              throws IOException

Throws:

IOException

toJsonBytes

public ByteBuffer toJsonBytes()

getUrl

public String getUrl()