bosky101
commented
8 years ago ekaf implements a state machine that reconnects on disconnection events. there are timeouts only to refresh metadata and catch changes. So you don't have to do anything on such events. It's abstracted.
That said - I will check out what case causes this. Also - was produce operations resuming post this?
Thanks ~B
On 27-May-2016, at 11:33 AM, Kunal Gupta notifications@github.com wrote:
I got weird error on connecting my erlang application to Kafka cluster. Please look into below errors.
ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.344719>} during ready ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.345988>} during ready ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.343701>} during ready ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.346711>} during ready ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.345919>} during ready ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.343695>} during ready ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.343845>} during ready ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.343866>} during ready ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.343674>} during ready ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.344163>} during ready
Can you tell me what is a connection timeout of ekaf with Kafka cluster and if timeout occurs do this automatically connect.
— You are receiving this because you are subscribed to this thread. Reply to this email directly, view it on GitHub, or mute the thread.
I got weird error on connecting my erlang application to Kafka cluster. Please look into below errors.
ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.344719>} during ready ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.345988>} during ready ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.343701>} during ready ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.346711>} during ready ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.345919>} during ready ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.343695>} during ready ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.343845>} during ready ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.343866>} during ready ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.343674>} during ready ekaf_server:472 <0.901.0>:dont know how to handle {tcp_closed,#Port<0.344163>} during ready
Can you tell me what is a connection timeout of ekaf with Kafka cluster and if timeout occurs do this automatically connect.