anchor.diff:    {noreply, State}.
   
   handle_call({start_producer, TopicName, ProducerConfig}, _From, State) ->
  -  case State#state.producers_sup of
  -    undefined ->
  -      Producers = [{TopicName, ProducerConfig}],
  -      {ok, Pid_} = brod_producers_sup:start_link(self(), Producers),
  -      {reply, ok, State#state{producers_sup = Pid_}};
  -    SupPid ->
  -      Res = brod_producers_sup:start_producer(
  -              SupPid, self(), TopicName, ProducerConfig),
  -      case  Res of
  -        {ok, _} ->
  -          {reply, ok, State};
  -        {error, _} = Error ->
  -          {reply, Error, State}
  -      end
  +  Res = brod_producers_sup:start_producer(
  +          State#state.producers_sup, self(), TopicName, ProducerConfig),
  +  case Res of
  +    {ok, _} ->
  +      {reply, ok, State};
  +    {error, _} = Error ->
  +      {reply, Error, State}
     end;
   handle_call(get_workers_table, _From, State) ->
     {reply, State#state.workers_tab, State};
  
positive.code:   ClientId = State#state.client_id,
    Endpoints = State#state.endpoints,
    Sock = start_metadata_socket(ClientId, Endpoints),
    {ok, ProducersSupPid} = maybe_start_producers_sup(Producers),
    {ok, ConsumersSupPid} = maybe_start_consumers_sup(Consumers),
    {noreply, State#state{ meta_sock     = Sock
                         , producers_sup = ProducersSupPid
                         , consumers_sup = ConsumersSupPid
  
negative.code:     {error, Reason} -> start_metadata_socket(ClientId, Endpoints, Reason)
    end.
  
  %%%_* Emacs ====================================================================
  %%% Local Variables:
  %%% allout-layout: t
  