diff --git a/src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/FileWriter.java b/src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/FileWriter.java
index 3095057..c38fd64 100644
--- a/src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/FileWriter.java
+++ b/src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/FileWriter.java
@@ -263,8 +263,8 @@ public class FileWriter implements Closeable {
     }
 
     private boolean shouldWriteAvroAsBytes(SinkRecord record) {
-        return ((record.valueSchema().type() == Schema.Type.BYTES) &&
-            (ingestionProps.getDataFormat().equals(IngestionProperties.DATA_FORMAT.avro.toString())));
+        return (record.valueSchema().type() == Schema.Type.BYTES) &&
+            (ingestionProps.getDataFormat().equals(IngestionProperties.DATA_FORMAT.avro.toString()));
     }
 
     public void initializeRecordWriter(SinkRecord record) {