anchor.diff:              ekaf_socket:close(Sock),
               Partitions
           catch _C:_E ->
  -                  server_down
  +                  kafka_server_down
           end
   end,
   PingWorker =
  
positive.code:                     fun(W) ->
                              case PingWorker(T, W, Partitions) of
                                  true ->
                                      io:format("ping topic ~p worker ~p ok~n", [T, W]);
                                  false ->
                                      io:format("error: ping topic ~p worker ~p leader is old~n", [T, W]);
                                  E ->
  
negative.code:             ChatMsgOutgoing = {chatmsg, Timestamp, <<"chat">>, outgoing, From, To, <<"kafka message body 1">>, <<"kafka_mid1">>},
              case timer:tc(gen_server,call,[Pid, ChatMsgOutgoing]) of
                  {Time, ok} ->
                      %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])
  