I
Size: a a a
2021 January 28
OG
Надо под это зум собрать, с фейрверками и шампанским
AU
Скоро. Будет. Много. Инфы
Т
Всем привет! Может кто сталкивался с write errors в go либе
github.com/segmentio/kafka-go. формирую пачку для вставки и пишу по N месседжей. Крайне редко, но ловлю write errors. Интересует такой момент, есть ли возможность, получив write error быть уверенным, что вся пачка не вставится и делать просто снова ретрай вставки всей пачки?
SB
Всем привет! Может кто сталкивался с write errors в go либе
github.com/segmentio/kafka-go. формирую пачку для вставки и пишу по N месседжей. Крайне редко, но ловлю write errors. Интересует такой момент, есть ли возможность, получив write error быть уверенным, что вся пачка не вставится и делать просто снова ретрай вставки всей пачки?
Такая уверенность даже в теории невозможна.
Т
тогда какой варинт? писать меньшими пачками, чтобы если и потерять/задублить ивенты - не было так страшно?
SB
тогда какой варинт? писать меньшими пачками, чтобы если и потерять/задублить ивенты - не было так страшно?
А какие именно ошибки?
SB
тогда какой варинт? писать меньшими пачками, чтобы если и потерять/задублить ивенты - не было так страшно?
Обработчики идемпотентность уважают?
Т
спасибо, я еще сейчас поковыряю трейсы кафки во время write errors (ибо го либа немногословен при ошибке)
SB
спасибо, я еще сейчас поковыряю трейсы кафки во время write errors (ибо го либа немногословен при ошибке)
Код ошибки есть?