всем привет! я использую библиотеку для работы с кафкой: github.com/Shopify/sarama
Скажите пожалуйста, она умеет переподключаться к кафке в случае чего? Потому что у меня примерно такая логика:
В main функции я инициализирую свою структуру для работы с sarama, там же происходит и коннект к самой кафке. А дальше в http обработчик могут раз в X времени постучаться и тем самым вызвать отправку какой-то инфы в кафку, это происходит примерно вот так:
lb, err := json.Marshal(&location)
message := &sarama.ProducerMessage{Topic: s.config.KafkaLocationTopic, Value: sarama.StringEncoder(lb)}
s.kp.Input() <- message
Проблема моя в том, что иногда этот код не срабатывает. Ендпоинт просто отдает таймаут, думаю что проблема именно на этом этапе. Но как и когда они возникает - хз