From 9e5f495748aed6dc9bac17e861a2abe221db90fd Mon Sep 17 00:00:00 2001 From: hasher Date: Mon, 29 Jun 2020 20:46:30 +0530 Subject: [PATCH] Remove extra bracket from shouldWriteAvroAsBytes method --- .../microsoft/azure/kusto/kafka/connect/sink/FileWriter.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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) {