Package io.confluent.kafka.schemaregistry.maven

Class UploadSchemaRegistryMojo

java.lang.Object

org.apache.maven.plugin.AbstractMojo

io.confluent.kafka.schemaregistry.maven.SchemaRegistryMojo

io.confluent.kafka.schemaregistry.maven.UploadSchemaRegistryMojo

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.maven.plugin.ContextEnabled, org.apache.maven.plugin.Mojo

Direct Known Subclasses:

RegisterSchemaRegistryMojo, TestCompatibilitySchemaRegistryMojo, ValidateSchemaRegistryMojo

public abstract class UploadSchemaRegistryMojo
extends SchemaRegistryMojo

Field Summary

Fields

Modifier and Type	Field	Description
static final String	PERCENT_REPLACEMENT

Fields inherited from class io.confluent.kafka.schemaregistry.maven.SchemaRegistryMojo

client

Fields inherited from interface org.apache.maven.plugin.Mojo

ROLE

Constructor Summary

Constructors

Constructor	Description
UploadSchemaRegistryMojo()

Method Summary

Modifier and Type	Method	Description
protected static String	decode(String subject)
protected static <V> Map<String,V>	decode(Map<String,V> map)
protected static Map<String,Metadata>	decodeMetadata(Map<String,Metadata> map)
void	execute()
protected String	failureMessage()
protected abstract boolean	processSchema(String subject, File schemaPath, ParsedSchema schema, Map<String,Integer> schemaVersions)

Methods inherited from class io.confluent.kafka.schemaregistry.maven.SchemaRegistryMojo

client, close

Methods inherited from class org.apache.maven.plugin.AbstractMojo

getLog, getPluginContext, setLog, setPluginContext

Methods inherited from class java.lang.Object

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

Field Details

PERCENT_REPLACEMENT

public static final String PERCENT_REPLACEMENT

See Also:

• Constant Field Values

Constructor Details

UploadSchemaRegistryMojo

public UploadSchemaRegistryMojo()

Method Details

execute

public void execute()
             throws org.apache.maven.plugin.MojoExecutionException,
org.apache.maven.plugin.MojoFailureException

Throws:

org.apache.maven.plugin.MojoExecutionException

org.apache.maven.plugin.MojoFailureException

decodeMetadata

protected static Map<String,Metadata> decodeMetadata(Map<String,Metadata> map)

decode

protected static <V> Map<String,V> decode(Map<String,V> map)

decode

protected static String decode(String subject)

processSchema

protected abstract boolean processSchema(String subject,
 File schemaPath,
 ParsedSchema schema,
 Map<String,Integer> schemaVersions)
                                  throws IOException,
RestClientException

Throws:

IOException

RestClientException

failureMessage

protected String failureMessage()