Blizzard/node-rdkafka

Question about commit and disconnect after connection is lost

Open

#27 opened on Aug 30, 2016

View on GitHub
 (6 comments) (0 reactions) (1 assignee)JavaScript (385 forks)batch import
help wantedquestion

Repository metrics

Stars
 (1,979 stars)
PR merge metrics
 (No merged PRs in 30d)

Description

I noticed that when commit is called while connection to kafka is lost, the function never returns or throws any error.

How should I recover from this state?

I could set a timeout and assume the connection is lost if the function does not return within that period and try to establish connection with a different kafka server. However, the disconnect function does not return either when connection is lost. How do I perform the necessary clean up without the disconnect function?

Thanks in advance

Contributor guide