Package io.confluent.kafka.schemaregistry.maven

Class RegisterSchemaRegistryMojo

java.lang.Object

org.apache.maven.plugin.AbstractMojo

io.confluent.kafka.schemaregistry.maven.SchemaRegistryMojo

io.confluent.kafka.schemaregistry.maven.UploadSchemaRegistryMojo

io.confluent.kafka.schemaregistry.maven.RegisterSchemaRegistryMojo

All Implemented Interfaces:

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

@Mojo(name="register",
      configurator="custom-basic")
public class RegisterSchemaRegistryMojo
extends UploadSchemaRegistryMojo

Field Summary

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

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
RegisterSchemaRegistryMojo()

Method Summary

Modifier and Type	Method	Description
protected boolean	processSchema(String subject, File schemaPath, ParsedSchema schema, Map<String,Integer> schemaVersions)

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

decode, decode, decodeMetadata, execute, failureMessage

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

Constructor Details

RegisterSchemaRegistryMojo

public RegisterSchemaRegistryMojo()

Method Details

processSchema

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

Specified by:

processSchema in class UploadSchemaRegistryMojo

Throws:

IOException

RestClientException