Я думал, что это исправлено, но, по-видимому, что-то упустил: в 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}]}]}}}
Вождение Я просто немного схожу с ума, пытаясь найти проблему, любая помощь или направление будет принята с благодарностью.
спасибо.