Консюмер вычитывает сообщение, передает его на обработку и если происходит ошибка , то кафка консьюмер откатывает и оставляет незакомиченным.
Thread.currentThread().getStackTrace()
Есть строка джсона длинной 25000+ строк.
CREATE EXTENSION pgcrypto;
BEGIN;
// Partition 1 of 16
UPDATE .... WHERE left(digest(ID, 'sha256'),1) = '0'
COMMIT;
BEGIN;
// Partition 2 of 16
UPDATE .... WHERE left(digest(ID, 'sha256'),1) = '1'
COMMIT;while(true) {
event = waitForEvent()
...
}