From dae1611bec8da6f4456a76a20879e5192ca16838 Mon Sep 17 00:00:00 2001 From: Oliver Eikemeier Date: Fri, 11 Jun 2021 13:53:53 +0200 Subject: [PATCH] Minor style improvements Signed-off-by: Oliver Eikemeier --- .../kafka/serde/avromapper/GenericMapperHelper.java | 2 +- .../kafka/serde/confluent/SpecificAvroDeserializer.java | 6 ++++-- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/src/main/java/de/melsicon/kafka/serde/avromapper/GenericMapperHelper.java b/src/main/java/de/melsicon/kafka/serde/avromapper/GenericMapperHelper.java index 7490255..2952074 100644 --- a/src/main/java/de/melsicon/kafka/serde/avromapper/GenericMapperHelper.java +++ b/src/main/java/de/melsicon/kafka/serde/avromapper/GenericMapperHelper.java @@ -20,7 +20,7 @@ public static State stateMap(GenericEnumSymbol state) { return State.ON; default: - throw new IllegalArgumentException("Unexpected Enum value: " + state.toString()); + throw new IllegalArgumentException("Unexpected Enum value: " + state); } } diff --git a/src/main/java/de/melsicon/kafka/serde/confluent/SpecificAvroDeserializer.java b/src/main/java/de/melsicon/kafka/serde/confluent/SpecificAvroDeserializer.java index a83fee8..a7c0bba 100644 --- a/src/main/java/de/melsicon/kafka/serde/confluent/SpecificAvroDeserializer.java +++ b/src/main/java/de/melsicon/kafka/serde/confluent/SpecificAvroDeserializer.java @@ -8,6 +8,7 @@ import org.apache.avro.specific.SpecificRecord; import org.apache.kafka.common.errors.SerializationException; import org.apache.kafka.common.serialization.Deserializer; +import org.checkerframework.checker.nullness.qual.NonNull; import org.checkerframework.checker.nullness.qual.Nullable; public final class SpecificAvroDeserializer implements Deserializer { @@ -34,12 +35,13 @@ private static Schema schemaForClass(Class type) { } @Override + @SuppressWarnings("nullness:override.param") public void configure( - @Nullable Map deserializerConfig, boolean isDeserializerForRecordKeys) { + @Nullable Map deserializerConfig, boolean isDeserializerForRecordKeys) { Map specificAvroEnabledConfig = deserializerConfig == null ? new HashMap<>() - : new HashMap<>((Map) deserializerConfig); + : new HashMap<>(deserializerConfig); specificAvroEnabledConfig.put(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG, true); inner.configure(specificAvroEnabledConfig, isDeserializerForRecordKeys);