anchor.diff:                      %io:format("worker is all right: ~w ~w ms ~w ~w~n",[node(), Time/1000, N,Pid]),
                       ok;
                   {Time, Value} ->
  -                    io:format("error: worker is fail: ~w Reason: ~p ~w ~w ~w~n",[node(), Value, 50000, N,Pid])
  +                    io:format("error: ~p worker is fail: Reason: ~p ~p ~p ~p~n",[node(), Value, 50000, N,Pid])
               end
   	catch
   	    Class:Type ->
  -		io:format("error: ~w ~w ~w ~w~n",[node(), 60000, N,Pid])
  +		io:format("error: ~p ~p ~p ~p~n",[node(), 60000, N,Pid])
   	end
   end,
   
  
positive.code:                                     %io:format("ping topic ~p worker ~p ok~n", [T, W]),
                                      ok;
                                  false ->
                                      io:format("error: ping topic ~p worker ~p leader is old~n", [T, W]);
                                  E ->
                                      io:format("error: ping topic ~p worker ~p ~p~n", [T, W, E])
                              end
                      end, Workers);
                Error ->
                    io:format("error: ping topic ~p ~p~n", [T, Error])
            end
    end, Topics),
  
  
negative.code:                 PingRedisWorker(log_kafka, N, Worker)
          catch
              C2:E2 ->
                  io:format("error: ~p ~p:~p ~pno worker ~n", [node(), C2, E2, N])
          end
  end,
  lists:foreach(PingKafkaN, lists:seq(1, PoolSize)),
  