Почему нам нужны транзакционные гарантии для Kafka eos - PullRequest
0 голосов
/ 17 октября 2018

Теперь, когда идемпотентный производитель может предоставить ровно один раз гарантию для каждого TopicPartition, зачем нам нужны транзакции, чтобы обеспечить гарантии записи для нескольких TopicPartition?

1 Ответ

0 голосов
/ 18 октября 2018

Идемпотентный производитель гарантирует только один раз семантику для каждого отдельного Производит запрос, который он отправляет.Каждый идемпотентный запрос может быть успешным или неудачным, и все они независимы.

С другой стороны, транзакции позволяют группировать несколько запросов (потенциально ко многим разделам и многим брокерам) для обработки всехкак группа.Поэтому при совершении транзакции либо все они будут успешными, либо все они будут отброшены.

...