Skip to content

Commit

Permalink
CSP-623 KafkaAvroSerializer fails when schema.compatibility is specif…
Browse files Browse the repository at this point in the history
…ied in client configuration (#635)

KafkaAvroSerializer tries to initialize an Enum from a property file, without using the necessary Enum.valueOf() conversion.
This has been supplied.
  • Loading branch information
heritamas authored and raju-saravanan committed Dec 5, 2019
1 parent 977f484 commit f8f80a7
Showing 1 changed file with 4 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -109,7 +109,10 @@ public KafkaAvroSerializer(ISchemaRegistryClient schemaRegistryClient) {

@Override
public void configure(Map<String, ?> configs, boolean isKey) {
compatibility = (SchemaCompatibility) configs.get(SCHEMA_COMPATIBILITY);
compatibility = SchemaCompatibility.valueOf(
Utils.getOrDefaultAsString(configs, SCHEMA_COMPATIBILITY, SchemaCompatibility.DEFAULT_COMPATIBILITY.name())
.toUpperCase()
);

schemaGroup = Utils.getOrDefaultAsString(configs, SCHEMA_GROUP, DEFAULT_SCHEMA_GROUP);
schemaNameKeySuffix = Utils.getOrDefaultAsString(configs, SCHEMA_NAME_KEY_SUFFIX_, DEFAULT_SCHEMA_NAME_KEY_SUFFIX);
Expand Down

0 comments on commit f8f80a7

Please sign in to comment.