Schema-registry-plugin

This plugin is a fork of https://github.com/ImFlog/schema-registry-plugin. This fork extends the original by allowing registering schema sets (multiple avsc files that reference each other).

The aim of this plugin is to adapt the Confluent schema registry maven plugin for Gradle builds.

See gradle plugins portal for instructions about how to add the plugin to your build configuration.

When you do so, three tasks are added under registry group:

• downloadSchemasTask
• testSchemasCompatibilityTask
• registerSchemasTask What these tasks do and how to configure them is described in the following sections.

Download schemas

Like the name of the task imply, this task is responsible of retrieving schemas from a schema registry.

A DSL is available to configure the task:

schemaRegistry {
    url = 'http://localhost:8081/'
    download {
        subject('topic1-key', 'src/main/avro')
        subject('topic1-value', 'src/main/avro/values')
    }
}

You have to put the url where the script can reach the Schema Registry.

You need to specify the pairs (subjectName, outputDir) for all the schemas you want to download.

Test schemas compatibility

This task test compatibility between local schemas and schemas stored in the Schema Registry.

A DSL is available to specify what to test:

schemaRegistry {
    url = 'http://localhost:8081'
    compatibility {
        subject('mySubject', 'file/path')
        subject('otherSubject', 'other/path')
    }
}

You have to put the url where the script can reach the Schema Registry.

You have to list all the (subject, avsc file path) pairs that you want to test.

Register schemas

Once again the name speaks for itself. This task register schemas from a local path to a Schema Registry.

A DSL is available to specify what to register:

schemaRegistry {
    url = 'http://localhost:8081'
    register {
        subject('mySubject', ['file/path'])
        subject('otherSubject', ['other/path', 'other/path/depends/on/previous'])
    }
}

You have to put the url where the script can reach the Schema Registry.

You have to list all the (subject, avsc file path) pairs that you want to send. The order of the file paths in the list is significant. Any Avro Schema that contains another type must be after the other type in the list. So if you have a user-profile.avsc that references a type in address.avsc, you should declare the list as follows:

['address.avsc', 'user-profile.avsc'])