Fix logs in consumer (#98)

Author: makalaaneesh

debezium-server/debezium-server-ybexporter/src/main/java/io/debezium/server/ybexporter/QueueSegment.java

@@ -64,6 +64,7 @@ public QueueSegment(String datadirStr, long segmentNo, String filePath){
 
         es.queueSegmentCreated(segmentNo, filePath);
         long committedSize = es.getQueueSegmentCommittedSize(segmentNo);
+        LOGGER.info("Opened queue segment {}; byteCount={}, committedSize={}", filePath, byteCount, committedSize);
         if (committedSize < byteCount){
             truncateFileAfterOffset(committedSize);
         }
@@ -179,7 +180,6 @@ public boolean isClosed() {
             input = new BufferedReader(new FileReader(filePath));
             while ((line = input.readLine()) != null) {
                 last = line;
-                LOGGER.info("last line = {}", last);
                 if (last.equals(EOF_MARKER)){
                     return true;
                 }

debezium-server/debezium-server-ybexporter/src/main/java/io/debezium/server/ybexporter/YbExporterConsumer.java

@@ -206,7 +206,9 @@ public void handleBatch(List<ChangeEvent<Object, Object>> changeEvents, Debezium
             committer.markProcessed(event);
         }
         handleBatchComplete();
+        LOGGER.info("Fsynced batch with {} records", changeEvents.size());
         committer.markBatchFinished();
+        LOGGER.info("Committed batch complete with {} records", changeEvents.size());
         handleSnapshotOnlyComplete();
     }