Index
All Classes and Interfaces|All Packages|Constant Field Values
A
- ANY_FIELD - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveProtobufSchema
B
- BOOL - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveProtobufSchema
- BOOLEAN - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveAvroSchema
- BOOLEAN - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveJsonSchema
C
- checkName(String) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveProtobufSchema
- checkName(String) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema
- classToDataType - Variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema
- client - Variable in class io.confluent.kafka.schemaregistry.maven.SchemaRegistryMojo
- client() - Method in class io.confluent.kafka.schemaregistry.maven.SchemaRegistryMojo
- close() - Method in class io.confluent.kafka.schemaregistry.maven.SchemaRegistryMojo
- configureComponent(Object, PlexusConfiguration, ExpressionEvaluator, ClassRealm, ConfigurationListener) - Method in class io.confluent.kafka.schemaregistry.maven.CustomBasicComponentConfigurator
- convertToFormat(JsonNode, String) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveAvroSchema
-
Convert json schema template to avro format and validate generated schema
- convertToFormat(JsonNode, String) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveJsonSchema
-
Generate json schema and check for any errors
- convertToFormat(JsonNode, String) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveProtobufSchema
-
Converts json schema template to protobuf format
- convertToFormat(JsonNode, String) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema
- convertToFormatArray(JsonNode, String) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveAvroSchema
- convertToFormatArray(JsonNode, String, int) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveProtobufSchema
- convertToFormatForRecord(JsonNode, String) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveAvroSchema
- convertToFormatRecord(JsonNode, String) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveProtobufSchema
- CustomBasicComponentConfigurator - Class in io.confluent.kafka.schemaregistry.maven
- CustomBasicComponentConfigurator() - Constructor for class io.confluent.kafka.schemaregistry.maven.CustomBasicComponentConfigurator
D
- decode(String) - Static method in class io.confluent.kafka.schemaregistry.maven.UploadSchemaRegistryMojo
- decode(Map<String, V>) - Static method in class io.confluent.kafka.schemaregistry.maven.UploadSchemaRegistryMojo
- decodeMetadata(Map<String, Metadata>) - Static method in class io.confluent.kafka.schemaregistry.maven.UploadSchemaRegistryMojo
- defaultSchemaProviders() - Static method in class io.confluent.kafka.schemaregistry.maven.MojoUtils
- deleteConfig(String) - Method in class io.confluent.kafka.schemaregistry.maven.SetCompatibilityMojo
- DeriveAvroSchema - Class in io.confluent.kafka.schemaregistry.maven.derive.schema
- DeriveAvroSchema() - Constructor for class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveAvroSchema
- DeriveJsonSchema - Class in io.confluent.kafka.schemaregistry.maven.derive.schema
- DeriveJsonSchema() - Constructor for class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveJsonSchema
- DeriveProtobufSchema - Class in io.confluent.kafka.schemaregistry.maven.derive.schema
- DeriveProtobufSchema() - Constructor for class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveProtobufSchema
- DeriveSchema - Class in io.confluent.kafka.schemaregistry.maven.derive.schema
- DeriveSchema() - Constructor for class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema
- DeriveSchemaMojo - Class in io.confluent.kafka.schemaregistry.maven
- DeriveSchemaMojo() - Constructor for class io.confluent.kafka.schemaregistry.maven.DeriveSchemaMojo
- DeriveSchemaUtils - Class in io.confluent.kafka.schemaregistry.maven.derive.schema
- DeriveSchemaUtils() - Constructor for class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchemaUtils
- disabled - Variable in class io.confluent.kafka.schemaregistry.maven.Rule
- doc - Variable in class io.confluent.kafka.schemaregistry.maven.Rule
- domainRules - Variable in class io.confluent.kafka.schemaregistry.maven.RuleSet
- DOUBLE - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveAvroSchema
- DOUBLE - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveProtobufSchema
- DownloadSchemaRegistryMojo - Class in io.confluent.kafka.schemaregistry.maven
- DownloadSchemaRegistryMojo() - Constructor for class io.confluent.kafka.schemaregistry.maven.DownloadSchemaRegistryMojo
E
- enableAt - Variable in class io.confluent.kafka.schemaregistry.maven.RuleSet
- encode(String) - Method in class io.confluent.kafka.schemaregistry.maven.DownloadSchemaRegistryMojo
- encodingRules - Variable in class io.confluent.kafka.schemaregistry.maven.RuleSet
- execute() - Method in class io.confluent.kafka.schemaregistry.maven.DeriveSchemaMojo
- execute() - Method in class io.confluent.kafka.schemaregistry.maven.DownloadSchemaRegistryMojo
- execute() - Method in class io.confluent.kafka.schemaregistry.maven.SetCompatibilityMojo
- execute() - Method in class io.confluent.kafka.schemaregistry.maven.TestLocalCompatibilityMojo
- execute() - Method in class io.confluent.kafka.schemaregistry.maven.UploadSchemaRegistryMojo
- expr - Variable in class io.confluent.kafka.schemaregistry.maven.Rule
F
- failureMessage() - Method in class io.confluent.kafka.schemaregistry.maven.TestCompatibilitySchemaRegistryMojo
- failureMessage() - Method in class io.confluent.kafka.schemaregistry.maven.UploadSchemaRegistryMojo
- FIELD_ENTRY - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveProtobufSchema
- FixedMapConverter - Class in io.confluent.kafka.schemaregistry.maven
- FixedMapConverter() - Constructor for class io.confluent.kafka.schemaregistry.maven.FixedMapConverter
- fromConfiguration(ConverterLookup, PlexusConfiguration, Class<?>, Type[], Class<?>, ClassLoader, ExpressionEvaluator, ConfigurationListener) - Method in class io.confluent.kafka.schemaregistry.maven.FixedMapConverter
G
- getConfig(String) - Method in class io.confluent.kafka.schemaregistry.maven.SetCompatibilityMojo
- getFiles(File) - Method in class io.confluent.kafka.schemaregistry.maven.TestLocalCompatibilityMojo
- getListFromArray(JsonNode) - Static method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchemaUtils
- getNullSchema() - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema
- getPrimitiveSchema(JsonNode) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema
- getSchemaForArray(List<JsonNode>, String) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema
-
Generate schema for array in json format, this schema is used as template by other formats
- getSchemaForMultipleMessages(List<JsonNode>) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema
- getSchemaForRecord(ObjectNode) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema
-
Generate schema for record in json format, this schema is used as template by other formats
- getSchemaOfAllElements(List<JsonNode>, String) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema
- getSingleDataType(ObjectNode, ArrayNode) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema
- getSortedKeys(JsonNode) - Static method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchemaUtils
- getUnique(List<JsonNode>) - Static method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchemaUtils
- groupItems(JsonNode, List<JsonNode>, List<JsonNode>, List<JsonNode>) - Static method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchemaUtils
I
- IMPORT_ANY_FIELD - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveProtobufSchema
- INT - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveAvroSchema
- INT_32 - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveProtobufSchema
- INT_64 - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveProtobufSchema
- io.confluent.kafka.schemaregistry.maven - package io.confluent.kafka.schemaregistry.maven
- io.confluent.kafka.schemaregistry.maven.derive.schema - package io.confluent.kafka.schemaregistry.maven.derive.schema
K
L
- loadSchema(File, String, Map<String, SchemaProvider>) - Method in class io.confluent.kafka.schemaregistry.maven.TestLocalCompatibilityMojo
- LONG - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveAvroSchema
M
- mapper - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema
- mapper - Static variable in class io.confluent.kafka.schemaregistry.maven.DeriveSchemaMojo
- mergeArrays(List<JsonNode>, boolean, boolean) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema
-
Merging different field types of array into one type
- mergeMultipleDataTypes(ObjectNode, List<JsonNode>, List<JsonNode>, List<JsonNode>, boolean) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveAvroSchema
- mergeMultipleDataTypes(ObjectNode, List<JsonNode>, List<JsonNode>, List<JsonNode>, boolean) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveJsonSchema
-
Merge different records into one record and different arrays into one array Multiple data types are combined through oneOf
- mergeMultipleDataTypes(ObjectNode, List<JsonNode>, List<JsonNode>, List<JsonNode>, boolean) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveProtobufSchema
-
Merge different records into one record and merge number types: double and int/long If there are multiple data types or nested arrays error is returned
- mergeMultipleDataTypes(ObjectNode, List<JsonNode>, List<JsonNode>, List<JsonNode>, boolean) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema
- mergeMultipleMessages(List<JsonNode>, Map<JsonNode, ArrayNode>) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveAvroSchema
-
Using mergeRecords to combine number and union types of fields
- mergeMultipleMessages(List<JsonNode>, Map<JsonNode, ArrayNode>) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveJsonSchema
-
Merge the unique schemas into one record by combining fields and merging data types
- mergeMultipleMessages(List<JsonNode>, Map<JsonNode, ArrayNode>) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveProtobufSchema
-
Merge schemas for multiple messages to combine records and number types
- mergeMultipleMessages(List<JsonNode>, Map<JsonNode, ArrayNode>) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema
- mergeNumberTypes(List<JsonNode>) - Static method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchemaUtils
- mergeRecords(List<JsonNode>) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema
-
Merge fields in all the records together into one record
- mergeUnions(List<JsonNode>, List<JsonNode>) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveAvroSchema
-
Check for fields with type union and null value, and if possible merge them Check recursively for records if there are multiple types
- Metadata - Class in io.confluent.kafka.schemaregistry.maven
- Metadata() - Constructor for class io.confluent.kafka.schemaregistry.maven.Metadata
- migrationRules - Variable in class io.confluent.kafka.schemaregistry.maven.RuleSet
- mode - Variable in class io.confluent.kafka.schemaregistry.maven.Rule
- MojoUtils - Class in io.confluent.kafka.schemaregistry.maven
- MojoUtils() - Constructor for class io.confluent.kafka.schemaregistry.maven.MojoUtils
N
- name - Variable in class io.confluent.kafka.schemaregistry.maven.Reference
- name - Variable in class io.confluent.kafka.schemaregistry.maven.Rule
- NULL - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveAvroSchema
- NULL - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveJsonSchema
- NUMBER - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveJsonSchema
O
- onFailure - Variable in class io.confluent.kafka.schemaregistry.maven.Rule
- onSuccess - Variable in class io.confluent.kafka.schemaregistry.maven.Rule
- outputDirValidation() - Method in class io.confluent.kafka.schemaregistry.maven.DownloadSchemaRegistryMojo
P
- params - Variable in class io.confluent.kafka.schemaregistry.maven.Rule
- parseSchema(String, String, List<SchemaReference>, Map<String, SchemaProvider>) - Method in class io.confluent.kafka.schemaregistry.maven.TestLocalCompatibilityMojo
- PERCENT_REPLACEMENT - Static variable in class io.confluent.kafka.schemaregistry.maven.DownloadSchemaRegistryMojo
- PERCENT_REPLACEMENT - Static variable in class io.confluent.kafka.schemaregistry.maven.UploadSchemaRegistryMojo
- PRIMITIVE_SCHEMA_TYPE - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema
- processSchema(String, File, ParsedSchema, Map<String, Integer>) - Method in class io.confluent.kafka.schemaregistry.maven.RegisterSchemaRegistryMojo
- processSchema(String, File, ParsedSchema, Map<String, Integer>) - Method in class io.confluent.kafka.schemaregistry.maven.TestCompatibilitySchemaRegistryMojo
- processSchema(String, File, ParsedSchema, Map<String, Integer>) - Method in class io.confluent.kafka.schemaregistry.maven.UploadSchemaRegistryMojo
- processSchema(String, File, ParsedSchema, Map<String, Integer>) - Method in class io.confluent.kafka.schemaregistry.maven.ValidateSchemaRegistryMojo
- properties - Variable in class io.confluent.kafka.schemaregistry.maven.Metadata
- PROTOBUF_SYNTAX - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveProtobufSchema
R
- readFile(File, Charset) - Static method in class io.confluent.kafka.schemaregistry.maven.MojoUtils
- readLinesOfMessages(File) - Static method in class io.confluent.kafka.schemaregistry.maven.DeriveSchemaMojo
- Reference - Class in io.confluent.kafka.schemaregistry.maven
- Reference() - Constructor for class io.confluent.kafka.schemaregistry.maven.Reference
- RegisterSchemaRegistryMojo - Class in io.confluent.kafka.schemaregistry.maven
- RegisterSchemaRegistryMojo() - Constructor for class io.confluent.kafka.schemaregistry.maven.RegisterSchemaRegistryMojo
- replaceEachField(JsonNode, List<JsonNode>) - Static method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchemaUtils
- Rule - Class in io.confluent.kafka.schemaregistry.maven
- Rule() - Constructor for class io.confluent.kafka.schemaregistry.maven.Rule
- RuleSet - Class in io.confluent.kafka.schemaregistry.maven
- RuleSet() - Constructor for class io.confluent.kafka.schemaregistry.maven.RuleSet
S
- SchemaRegistryMojo - Class in io.confluent.kafka.schemaregistry.maven
- SchemaRegistryMojo() - Constructor for class io.confluent.kafka.schemaregistry.maven.SchemaRegistryMojo
- sensitive - Variable in class io.confluent.kafka.schemaregistry.maven.Metadata
- SetCompatibilityMojo - Class in io.confluent.kafka.schemaregistry.maven
- SetCompatibilityMojo() - Constructor for class io.confluent.kafka.schemaregistry.maven.SetCompatibilityMojo
- sortJsonArrayList(ArrayNode) - Static method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchemaUtils
- sortObjectNode(ObjectNode) - Static method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchemaUtils
- STRING - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveAvroSchema
- STRING - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveJsonSchema
- STRING - Static variable in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveProtobufSchema
- subject - Variable in class io.confluent.kafka.schemaregistry.maven.Reference
T
- tags - Variable in class io.confluent.kafka.schemaregistry.maven.Metadata
- tags - Variable in class io.confluent.kafka.schemaregistry.maven.Rule
- TestCompatibilitySchemaRegistryMojo - Class in io.confluent.kafka.schemaregistry.maven
- TestCompatibilitySchemaRegistryMojo() - Constructor for class io.confluent.kafka.schemaregistry.maven.TestCompatibilitySchemaRegistryMojo
- TestLocalCompatibilityMojo - Class in io.confluent.kafka.schemaregistry.maven
- TestLocalCompatibilityMojo() - Constructor for class io.confluent.kafka.schemaregistry.maven.TestLocalCompatibilityMojo
- testSchema(String, Map<String, SchemaProvider>) - Method in class io.confluent.kafka.schemaregistry.maven.TestLocalCompatibilityMojo
- toMetadataEntity() - Method in class io.confluent.kafka.schemaregistry.maven.Metadata
- toRuleEntity() - Method in class io.confluent.kafka.schemaregistry.maven.Rule
- toRuleSetEntity() - Method in class io.confluent.kafka.schemaregistry.maven.RuleSet
- toString() - Method in class io.confluent.kafka.schemaregistry.maven.Metadata
- toString() - Method in class io.confluent.kafka.schemaregistry.maven.Reference
- toString() - Method in class io.confluent.kafka.schemaregistry.maven.Rule
- toString() - Method in class io.confluent.kafka.schemaregistry.maven.RuleSet
- type - Variable in class io.confluent.kafka.schemaregistry.maven.Rule
U
- updateConfig(String, CompatibilityLevel) - Method in class io.confluent.kafka.schemaregistry.maven.SetCompatibilityMojo
- updateSchemaInformation(JsonNode, ArrayNode, ArrayNode) - Method in class io.confluent.kafka.schemaregistry.maven.derive.schema.DeriveSchema
- UploadSchemaRegistryMojo - Class in io.confluent.kafka.schemaregistry.maven
- UploadSchemaRegistryMojo() - Constructor for class io.confluent.kafka.schemaregistry.maven.UploadSchemaRegistryMojo
V
- ValidateSchemaRegistryMojo - Class in io.confluent.kafka.schemaregistry.maven
- ValidateSchemaRegistryMojo() - Constructor for class io.confluent.kafka.schemaregistry.maven.ValidateSchemaRegistryMojo
- version - Variable in class io.confluent.kafka.schemaregistry.maven.Reference
W
- writeOutput(File, JsonNode) - Static method in class io.confluent.kafka.schemaregistry.maven.DeriveSchemaMojo
All Classes and Interfaces|All Packages|Constant Field Values