Получение Producer_down в Erlang / Brod, но нет проблем в реализации java - PullRequest
1 голос
/ 31 марта 2020

Я думал, что это исправлено, но, по-видимому, что-то упустил: в Erlang / Brod я получаю ошибку производителя

  {ok, _} = application:ensure_all_started(brod),
  ok = brod:start_client(KafkaBootstrapEnpoint, client1, _client_config = []),

  ok = brod:start_producer(client1, KafkaQ, _ProducerConfig = []),
  {ok, Partition_count} = brod:get_partitions_count(client1, KafkaQ ),
  case catch brod:produce_sync(client1, KafkaQ, KafkaPartition, <<"key1">>, <<"Key2">>) of
      {ok, _} ->
        ok;
      Error ->
        io:format("unexpedted response for partition: ~p error: ~p ~n", [KafkaPartition, Error])
  end,

Сообщение об ошибке выглядит следующим образом:

> =INFO REPORT==== 31-Mar-2020::07:59:45 ===
client client1 connected to 10.10.1.35:9092
unexpedted response for partition: 1 error: {error,
                                             {producer_down,
                                              {{crc32cer_nif_not_loaded,
                                                "/home/roger/IdeaProjects/redis/_build/default/lib/crc32cer/priv/crc32cer"},
                                               [{erlang,nif_error,
                                                 [{crc32cer_nif_not_loaded,
                                                   "/home/roger/IdeaProjects/redis/_build/default/lib/crc32cer/priv/crc32cer"}],
                                                 []},
                                                {crc32cer,nif,2,
                                                 [{file,
                                                   "/home/roger/IdeaProjects/redis/_build/default/lib/crc32cer/src/crc32cer.erl"},
                                                  {line,23}]},
                                                {kpro_batch,encode_tx,4,
                                                 [{file,
                                                   "/home/roger/IdeaProjects/redis/_build/default/lib/kafka_protocol/src/kpro_batch.erl"},
                                                  {line,97}]},
                                                {kpro_batch,encode,3,
                                                 [{file,
                                                   "/home/roger/IdeaProjects/redis/_build/default/lib/kafka_protocol/src/kpro_batch.erl"},
                                                  {line,47}]},
                                                {kpro_req_lib,produce,5,
                                                 [{file,
                                                   "/home/roger/IdeaProjects/redis/_build/default/lib/kafka_protocol/src/kpro_req_lib.erl"},
                                                  {line,206}]},
                                                {brod_producer,
                                                 '-init/1-fun-0-',8,
                                                 [{file,
                                                   "/home/roger/IdeaProjects/redis/_build/default/lib/brod/src/brod_producer.erl"},
                                                  {line,285}]},
                                                {brod_producer_buffer,
                                                 do_send,4,
                                                 [{file,
                                                   "/home/roger/IdeaProjects/redis/_build/default/lib/brod/src/brod_producer_buffer.erl"},
                                                  {line,273}]},
                                                {brod_producer,maybe_produce,
                                                 1,
                                                 [{file,
                                                   "/home/roger/IdeaProjects/redis/_build/default/lib/brod/src/brod_producer.erl"},
                                                  {line,498}]}]}}}

Вождение Я просто немного схожу с ума, пытаясь найти проблему, любая помощь или направление будет принята с благодарностью.

спасибо.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...