наткнулся на критичный баг в кафка стримах (как https://issues.apache.org/jira/browse/KAFKA-7192) и возможно он появился как раз после этого фикса.
Баг у меня проявляется в том что когда таск возвращается с другого инстансна приложения при ребалансе - то у него стор не ресторится и остается пустым - и это с включенным EOS. Может есть какой-то гиттер где можно с разрабами кафка стримов поговорить?
К сожалению у меня нет сейчас кода расшарить (на работе завал и дома тоже :) )
https://launchpass.com/confluentcommunity
Обсуждают сегодня