thank u for good job for this project
when use sarama, i come across a problem that how could i catch the connect error to reconnect? any idea for that? thank u:)
:+1:
Sarama should try to (re)connect to the Kafka cluster automatically on network errors.
MetadataRetries and WaitForElection in the ClientConfig to change how often and how soon to retry. See https://godoc.org/github.com/Shopify/sarama#ClientConfigIf that doesn't work, can you set sarama.Logger to capture the output, and paste it here?
Closing for lack of response. Please feel free to re-open if you have more questions.
Most helpful comment
Sarama should try to (re)connect to the Kafka cluster automatically on network errors.
MetadataRetriesandWaitForElectionin the ClientConfig to change how often and how soon to retry. See https://godoc.org/github.com/Shopify/sarama#ClientConfigIf that doesn't work, can you set
sarama.Loggerto capture the output, and paste it here?