diff --git a/src/main/java/net/coru/kloadgen/serializer/GenericAvroRecordBinarySerializer.java b/src/main/java/net/coru/kloadgen/serializer/GenericAvroRecordBinarySerializer.java
index 0363ab57..a7edf995 100644
--- a/src/main/java/net/coru/kloadgen/serializer/GenericAvroRecordBinarySerializer.java
+++ b/src/main/java/net/coru/kloadgen/serializer/GenericAvroRecordBinarySerializer.java
@@ -24,7 +24,7 @@ public class GenericAvroRecordBinarySerializer<T extends GenericRecord> implemen
 
   @Override
   public final byte[] serialize(final String s, final T data) {
-    DatumWriter<T> writer;
+    final DatumWriter<T> writer;
     if (data instanceof SpecificRecord) {
       writer = new SpecificDatumWriter<>(data.getSchema());
     } else {
diff --git a/src/main/java/net/coru/kloadgen/serializer/GenericAvroRecordSerializer.java b/src/main/java/net/coru/kloadgen/serializer/GenericAvroRecordSerializer.java
index dc4cca0a..5389f9c0 100644
--- a/src/main/java/net/coru/kloadgen/serializer/GenericAvroRecordSerializer.java
+++ b/src/main/java/net/coru/kloadgen/serializer/GenericAvroRecordSerializer.java
@@ -26,7 +26,7 @@ public class GenericAvroRecordSerializer<T extends GenericRecord> implements Ser
   @Override
   public final byte[] serialize(final String topic, final T data) {
 
-    DatumWriter<T> writer;
+    final DatumWriter<T> writer;
     if (data instanceof SpecificRecord) {
       writer = new SpecificDatumWriter<>(data.getSchema());
     } else {