update_price

func UpdatePrice ¶

func UpdatePrice(service service.Interface, brokers []string, topic, instance string)

UpdatePrice обновляет цену товара, находящегося в продаже, если считывает в топике store.update-price новую цену. Autocommit не выполняется. При ошибке обновления цены смещение в Кафке не сохраняется, а производятся новые попытки обновления. Каждая последующая попытка производится через период, на десять секунд дольше предыдущего. Через attemptsUntilAlarm попыток, в лог выводится ошибка, а не предупреждение.