You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
The problem is that I am connecting from a Kafka VM that is located on the host, because when calling brod:start_producer methods, it does not give an error with an incorrect IP. But if I want to send a message by any methods, such brod:produce*, it crashes with an error that apparently spent its connection attempts or something like that.
Everything works locally, but if you try to send a message from a VM, it won't work.
=ERROR REPORT==== 6-Feb-2023::07:16:53.667851 ===
** Generic server <0.128.0> terminating
** Last message in was retry
** When Server state == {state,<0.121.0>,<<"test-topic">>,0,undefined,
undefined,
{buf,512,1,1048576,3,0,0,
{fun brod_producer:do_send_fun/4,
{<<"test-topic">>,0,-1,10000,
no_compression}},
1,0,
{[],[]},
{[],[]},
[]},
500,#Ref<0.270554143.1606942722.251993>,
undefined,
{default,0}}
** Reason for termination ==
** {{reached_max_retries,no_leader_connection},
[{brod_producer_buffer,rebuffer_or_crash,3,
[{file,"/brod/src/brod_producer_buffer.erl"},
{line,312}]},
{brod_producer_buffer,do_send,4,
[{file,"/brod/src/brod_producer_buffer.erl"},
{line,296}]},
{brod_producer,maybe_produce,1,
[{file,"/brod/src/brod_producer.erl"},
{line,536}]},
{brod_producer,handle_info,2,
[{file,"/brod/src/brod_producer.erl"},
{line,333}]},
{gen_server,try_dispatch,4,[{file,"gen_server.erl"},{line,695}]},
{gen_server,handle_msg,6,[{file,"gen_server.erl"},{line,771}]},
{proc_lib,init_p_do_apply,3,[{file,"proc_lib.erl"},{line,226}]}]}
=CRASH REPORT==== 6-Feb-2023::07:16:53.668158 ===
crasher:
initial call: brod_producer:init/1
pid: <0.128.0>
registered_name: []
exception exit: {reached_max_retries,no_leader_connection}
in function brod_producer_buffer:rebuffer_or_crash/3 (/brod/src/brod_producer_buffer.erl, line 312)
in call from brod_producer_buffer:do_send/4 (/brod/src/brod_producer_buffer.erl, line 296)
in call from brod_producer:maybe_produce/1 (/brod/src/brod_producer.erl, line 536)
in call from brod_producer:handle_info/2 (/brod/src/brod_producer.erl, line 333)
in call from gen_server:try_dispatch/4 (gen_server.erl, line 695)
in call from gen_server:handle_msg/6 (gen_server.erl, line 771)
ancestors: [<0.126.0>,<0.124.0>,client1,brod_sup,<0.117.0>]
message_queue_len: 0
messages: []
links: [<0.126.0>]
dictionary: []
trap_exit: true
status: running
heap_size: 10958
stack_size: 28
reductions: 12730
neighbours:
** exception error: no match of right hand side value
{error,
{producer_down,{reached_max_retries,no_leader_connection}}}
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
-
The problem is that I am connecting from a Kafka VM that is located on the host, because when calling brod:start_producer methods, it does not give an error with an incorrect IP. But if I want to send a message by any methods, such brod:produce*, it crashes with an error that apparently spent its connection attempts or something like that.
Everything works locally, but if you try to send a message from a VM, it won't work.
=ERROR REPORT==== 6-Feb-2023::07:16:53.667851 ===
** Generic server <0.128.0> terminating
** Last message in was retry
** When Server state == {state,<0.121.0>,<<"test-topic">>,0,undefined,
undefined,
{buf,512,1,1048576,3,0,0,
{fun brod_producer:do_send_fun/4,
{<<"test-topic">>,0,-1,10000,
no_compression}},
1,0,
{[],[]},
{[],[]},
[]},
500,#Ref<0.270554143.1606942722.251993>,
undefined,
{default,0}}
** Reason for termination ==
** {{reached_max_retries,no_leader_connection},
[{brod_producer_buffer,rebuffer_or_crash,3,
[{file,"/brod/src/brod_producer_buffer.erl"},
{line,312}]},
{brod_producer_buffer,do_send,4,
[{file,"/brod/src/brod_producer_buffer.erl"},
{line,296}]},
{brod_producer,maybe_produce,1,
[{file,"/brod/src/brod_producer.erl"},
{line,536}]},
{brod_producer,handle_info,2,
[{file,"/brod/src/brod_producer.erl"},
{line,333}]},
{gen_server,try_dispatch,4,[{file,"gen_server.erl"},{line,695}]},
{gen_server,handle_msg,6,[{file,"gen_server.erl"},{line,771}]},
{proc_lib,init_p_do_apply,3,[{file,"proc_lib.erl"},{line,226}]}]}
=CRASH REPORT==== 6-Feb-2023::07:16:53.668158 ===
crasher:
initial call: brod_producer:init/1
pid: <0.128.0>
registered_name: []
exception exit: {reached_max_retries,no_leader_connection}
in function brod_producer_buffer:rebuffer_or_crash/3 (/brod/src/brod_producer_buffer.erl, line 312)
in call from brod_producer_buffer:do_send/4 (/brod/src/brod_producer_buffer.erl, line 296)
in call from brod_producer:maybe_produce/1 (/brod/src/brod_producer.erl, line 536)
in call from brod_producer:handle_info/2 (/brod/src/brod_producer.erl, line 333)
in call from gen_server:try_dispatch/4 (gen_server.erl, line 695)
in call from gen_server:handle_msg/6 (gen_server.erl, line 771)
ancestors: [<0.126.0>,<0.124.0>,client1,brod_sup,<0.117.0>]
message_queue_len: 0
messages: []
links: [<0.126.0>]
dictionary: []
trap_exit: true
status: running
heap_size: 10958
stack_size: 28
reductions: 12730
neighbours:
** exception error: no match of right hand side value
{error,
{producer_down,{reached_max_retries,no_leader_connection}}}
Beta Was this translation helpful? Give feedback.
All reactions