anchor.diff:  end,
   
   INFO = fun(Format, Args) ->
  -               error_logger:info_msg(Format, Args),
  -               io:format(Format, Args)
  +               error_logger:info_msg(Format, Args)
  +       end,
  +ERROR_MSG = fun(Format, Args) ->
  +               error_logger:error_msg(Format, Args)
          end,
   StrToTerm = fun(Str) ->
                       case erl_scan:string(Str++".") of
  
positive.code:                         Plist = jsx:decode(Str),
                          case FindTopic(Plist) of
                              undefined -> 
                                  INFO("RepairKafka: Cannot Find Topic:plist=~p~n", [Plist]),
                                  {fail, skip};
                              TopicName ->
                                  case IsWriteKafka of
  
negative.code:                               INFO("RepairKafka: Produce ok: ~p on message ~s ~n", [Topic, Value]),
                                ok;
                            Error ->
                                ERROR_MSG("RepairKafka: ProduceError: ~p on message ~s ~n", [Error, Value]),
                                {fail, Error}
                        end
                end,
  