как их посмотреть?
Это не замена постгресу, это потоковая обработка. Поток на входе, поток на выходе. Поток на выходе может заливаться в базу данных, при желании. Вопрос же возникает в том, что при необходимости делать хоть немного сложные операции приходится заморачиваться с консистентностью всего этого безобразия.
> хоть немного сложные операции Это какие? И о какой консистентности идёт речь?
Например, агрегации или join. Например идёт речь о гарантии exactly once при обработке данных.
Exactly once делается не сложно. Каждый степ запоминает всех, кого обработал. При выходе из пайплайна, последний степ ACK-ает клиенту, который послал сообщение, и атомарно посылает ACK каждому степу, чтобы они забыли это обработанное сообщение. Всё
Обсуждают сегодня