package com.kafkaconsumer.groups;

import java.io.File;
import java.io.OutputStream;
import java.io.Writer;
import java.io.OutputStreamWriter;
import java.io.FileOutputStream;

public class LogWriter {
  private OutputStreamWriter osw;
  
  
  public LogWriter(String path) {
    File fout = new File(path);
	  FileOutputStream fos = new FileOutputStream(fout);
 	  osw = new OutputStreamWriter(fos);
  
  }

  public OutputStreamWriter getWriter() {
  return osw;
  }



}

@@ -301,16 +301,31 @@
 (path);%0A
+    %0A    try %7B%0A
 %09  FileO
@@ -371,17 +371,99 @@
 fout);%0A 
-%09
+   %7D catch (FileNotFoundException e) %7B%0A        %0A        e.printStackTrace();%0A    %0A 
   osw = 

Update LogWriter.java