package com.kafkaconsumer.groups;

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

public class LogWriter {
  private OutputStreamWriter osw;
  
  
  public LogWriter(String path) {
    File fout = new File(path);
    
    try {
	  FileOutputStream fos = new FileOutputStream(fout);
    } catch (FileNotFoundException e) {
        
        e.printStackTrace(); }
    
   osw = new OutputStreamWriter(fos);
  
  }

  public OutputStreamWriter getWriter() {
  return osw;
  }



}

@@ -408,16 +408,54 @@
 (fout);%0A
+%09  osw = new OutputStreamWriter(fos);%0A
     %7D ca
@@ -537,43 +537,8 @@
  %0A  
- osw = new OutputStreamWriter(fos);
 %0A  %0A

Update LogWriter.java