anchor.diff:                  PingRedisWorker(log_kafka, N, Worker)
           catch
               C2:E2 ->
  -                io:format("error:~p ~p:~p ~pno worker ~n", [node(), C2, E2, N])
  +                io:format("error: ~p ~p:~p ~pno worker ~n", [node(), C2, E2, N])
           end
   end,
   lists:foreach(PingKafkaN, lists:seq(1, PoolSize)),
  
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:           Partitions = GetPartitions(T),
            case Partitions of
                [] ->
                    io:format("error: ~p ping topic ~p failed~n", [node(), T]);
                [_H|_T] ->
                    lists:foreach(
                      fun(W) ->
  