Всем привет! я использую библиотеку для работы с кафкой: github.com/Shopify/sarama Скажите

Question

Всем привет! я использую библиотеку для работы с кафкой: 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

Проблема моя в том, что иногда этот код не срабатывает. Ендпоинт просто отдает таймаут, думаю что проблема именно на этом этапе. Но как и когда они возникает - хз

#backend #go #programming #russian

0

10.05.2021