Package io.confluent.kafka.schemaregistry.tools

Class CheckSchemaCompatibility

java.lang.Object

io.confluent.kafka.schemaregistry.tools.CheckSchemaCompatibility

All Implemented Interfaces:

Callable<Integer>

public class CheckSchemaCompatibility
extends Object
implements Callable<Integer>

Constructor Summary

Constructors

Constructor	Description
CheckSchemaCompatibility()

Method Summary

Modifier and Type	Method	Description
Integer	call()
protected boolean	compareSubject(SchemaRegistryClient sourceClient, SchemaRegistryClient targetClient, String subject)
protected boolean	compareSubjects(List<String> sourceSubjects, List<String> targetSubjects, SchemaRegistryClient sourceClient, SchemaRegistryClient targetClient)
protected boolean	compareVersion(SchemaRegistryClient sourceClient, SchemaRegistryClient targetClient, String subject, Integer version)
static void	main(String[] args)

Methods inherited from class java.lang.Object

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

Constructor Details

CheckSchemaCompatibility

public CheckSchemaCompatibility()

Method Details

call

public Integer call()
             throws Exception

Specified by:

call in interface Callable<Integer>

Throws:

Exception

compareSubjects

protected boolean compareSubjects(List<String> sourceSubjects,
 List<String> targetSubjects,
 SchemaRegistryClient sourceClient,
 SchemaRegistryClient targetClient)
                           throws RestClientException,
IOException

Throws:

RestClientException

IOException

compareSubject

protected boolean compareSubject(SchemaRegistryClient sourceClient,
 SchemaRegistryClient targetClient,
 String subject)
                          throws RestClientException,
IOException

Throws:

RestClientException

IOException

compareVersion

protected boolean compareVersion(SchemaRegistryClient sourceClient,
 SchemaRegistryClient targetClient,
 String subject,
 Integer version)
                          throws RestClientException,
IOException

Throws:

RestClientException

IOException

main

public static void main(String[] args)