Gymterview
junior

Какова роль Transactions API?

Transactions API позволяет выполнять атомарные обновления для нескольких топиков. Он обеспечивает exactly-once гарантию для приложений, которые читают данные из одного топика и пишут в другой. Это критически важно для потоковой обработки, где каждое входное событие должно повлиять на выходные данные ровно один раз, даже в случае сбоев.

На собеседовании: Transactions API — это продвинутая тема. Упомяните, что для включения нужны enable.idempotence=true и transactional.id у продюсера, а консюмер должен использовать isolation.level=read_committed.