{"id":494600,"date":"2026-09-14T13:04:48","date_gmt":"2026-09-14T13:04:48","guid":{"rendered":"https:\/\/savepearlharbor.com\/?p=494600"},"modified":"-0001-11-30T00:00:00","modified_gmt":"-0001-11-29T21:00:00","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=494600","title":{"rendered":"\u041e\u0447\u0435\u0440\u0435\u0434\u044c \u043d\u0430 Postgres: \u043f\u043e\u0447\u0435\u043c\u0443 Kafka \u043d\u0435 \u043d\u0443\u0436\u043d\u0430"},"content":{"rendered":"<div xmlns=\"http:\/\/www.w3.org\/1999\/xhtml\">\n<figure class=\"\"><img decoding=\"async\" src=\"https:\/\/habrastorage.org\/r\/w1560\/getpro\/habr\/upload_files\/3cc\/18d\/0d5\/3cc18d0d5bf2f468408f7e8c002af9a6.png\" alt=\"\u041a\u0414\u041f\u0412\" title=\"\u041a\u0430\u0440\u0442\u0438\u043d\u043a\u0430 \u0434\u043b\u044f \u043f\u0440\u0438\u0432\u043b\u0435\u0447\u0435\u043d\u0438\u044f \u0432\u043d\u0438\u043c\u0430\u043d\u0438\u044f\" sizes=\"(max-width: 780px) 100vw, 50vw\" srcset=\"https:\/\/habrastorage.org\/r\/w780\/getpro\/habr\/upload_files\/3cc\/18d\/0d5\/3cc18d0d5bf2f468408f7e8c002af9a6.png 780w,&#10;       https:\/\/habrastorage.org\/r\/w1560\/getpro\/habr\/upload_files\/3cc\/18d\/0d5\/3cc18d0d5bf2f468408f7e8c002af9a6.png 781w\" loading=\"lazy\" decode=\"async\"\/><\/p>\n<div><figcaption>\u041a\u0430\u0440\u0442\u0438\u043d\u043a\u0430 \u0434\u043b\u044f \u043f\u0440\u0438\u0432\u043b\u0435\u0447\u0435\u043d\u0438\u044f \u0432\u043d\u0438\u043c\u0430\u043d\u0438\u044f<\/figcaption><\/div>\n<\/figure>\n<p>\u042d\u0442\u043e \u0438\u0441\u0442\u043e\u0440\u0438\u044f \u043f\u0440\u043e \u0430\u0440\u0445\u0438\u0442\u0435\u043a\u0442\u0443\u0440\u0443 \u043e\u0434\u043d\u043e\u0433\u043e \u0441\u0435\u0440\u0432\u0438\u0441\u0430. \u0420\u0430\u0441\u0441\u043a\u0430\u0437\u0430\u043d\u043d\u0430\u044f \u0434\u043e \u043a\u043e\u043d\u0446\u0430, \u0430 \u043d\u0435 \u0442\u043e\u043b\u044c\u043a\u043e \u0434\u043e \u0442\u043e\u0433\u043e \u043c\u0435\u0441\u0442\u0430, \u0433\u0434\u0435 \u043e\u0431\u044b\u0447\u043d\u043e \u043e\u0441\u0442\u0430\u043d\u0430\u0432\u043b\u0438\u0432\u0430\u044e\u0442\u0441\u044f \u0441\u0442\u0430\u0442\u044c\u0438 \u043f\u0440\u043e \u0430\u0440\u0445\u0438\u0442\u0435\u043a\u0442\u0443\u0440\u0443. \u041d\u0430\u043c\u0435\u0440\u0435\u043d\u043d\u043e \u0443\u043f\u0440\u043e\u0449\u0435\u043d\u0430 \u0431\u0438\u0437\u043d\u0435\u0441-\u043b\u043e\u0433\u0438\u043a\u0430, \u0447\u0442\u043e\u0431\u044b \u043d\u0435 \u0440\u0430\u0437\u043c\u044b\u0432\u0430\u0442\u044c \u043e\u0441\u043d\u043e\u0432\u043d\u043e\u0439 \u0441\u043c\u044b\u0441\u043b.<\/p>\n<h2>\u0413\u043b\u0430\u0432\u0430 1. \u0412 \u043d\u0430\u0447\u0430\u043b\u0435 \u0431\u044b\u043b\u043e \u043f\u0440\u043e\u0441\u0442\u043e<\/h2>\n<p>\u0421\u0435\u0440\u0432\u0438\u0441 \u043f\u0440\u0438\u043d\u0438\u043c\u0430\u043b \u0437\u0430\u043f\u0440\u043e\u0441, \u043f\u0438\u0441\u0430\u043b \u0441\u0442\u0440\u043e\u043a\u0443 \u0432 \u0431\u0430\u0437\u0443, \u043e\u0442\u0432\u0435\u0447\u0430\u043b 201. \u042d\u0442\u043e \u0432\u0435\u0441\u044c \u043a\u043e\u0434:<\/p>\n<pre><code class=\"cs\">app.MapPost(\"\/direct\", async (Message dto, AppDbContext db, CancellationToken ct) =&gt;{    Message msg = new() { Content = dto.Content, CreatedAt = DateTime.UtcNow };    db.Messages.Add(msg);    await db.SaveChangesAsync(ct);    return Results.Created($\"\/messages\/{msg.Id}\", msg);});<\/code><div class=\"code-explainer\"><a href=\"https:\/\/sourcecraft.dev\/\" class=\"tm-button code-explainer__link\" style=\"visibility: hidden;\"><img style=\"width:87px;height:14px;object-fit:cover;object-position:left;\"\/><\/a><\/div><\/pre>\n<p>\u041d\u0438\u043a\u0442\u043e \u043d\u0435 \u043f\u0438\u0448\u0435\u0442 \u0441\u0442\u0430\u0442\u0435\u0439 \u043f\u0440\u043e \u044d\u0442\u043e\u0442 \u043a\u043e\u0434, \u043f\u043e\u0442\u043e\u043c\u0443 \u0447\u0442\u043e \u0432 \u043d\u0451\u043c \u043d\u0435\u0447\u0435\u0433\u043e \u043e\u0431\u0441\u0443\u0436\u0434\u0430\u0442\u044c. \u041d\u043e \u0438\u043c\u0435\u043d\u043d\u043e \u043e\u0431 \u043d\u0435\u0433\u043e \u0440\u0430\u0437\u0431\u0438\u0432\u0430\u044e\u0442\u0441\u044f \u0432\u0441\u0435 \u043f\u043e\u0441\u043b\u0435\u0434\u0443\u044e\u0449\u0438\u0435 \u0440\u0435\u0448\u0435\u043d\u0438\u044f \u2014 \u0434\u0435\u0440\u0436\u0438\u0442\u0435 \u0435\u0433\u043e \u0432 \u0433\u043e\u043b\u043e\u0432\u0435, \u043e\u043d \u0435\u0449\u0451 \u043f\u0440\u0438\u0433\u043e\u0434\u0438\u0442\u0441\u044f \u0432 \u0444\u0438\u043d\u0430\u043b\u0435.<\/p>\n<h2>\u0413\u043b\u0430\u0432\u0430 2. \u00ab\u041d\u0430\u043c \u043d\u0443\u0436\u043d\u0430 \u043e\u0447\u0435\u0440\u0435\u0434\u044c\u00bb \u2014 \u0438 \u0432\u043e\u0442 \u043f\u043e\u0447\u0435\u043c\u0443 \u044d\u0442\u043e \u043d\u0435 \u0433\u043b\u0443\u043f\u043e\u0441\u0442\u044c<\/h2>\n<p>\u0420\u0430\u043d\u043e \u0438\u043b\u0438 \u043f\u043e\u0437\u0434\u043d\u043e \u043e\u0434\u0438\u043d \u0441\u0435\u0440\u0432\u0438\u0441 \u043f\u0435\u0440\u0435\u0441\u0442\u0430\u0451\u0442 \u0431\u044b\u0442\u044c \u043e\u0434\u043d\u0438\u043c \u0441\u0435\u0440\u0432\u0438\u0441\u043e\u043c. \u041f\u043e\u044f\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u0432\u0442\u043e\u0440\u043e\u0439, \u043a\u043e\u0442\u043e\u0440\u043e\u043c\u0443 \u0432\u0430\u0436\u043d\u043e \u0443\u0437\u043d\u0430\u0442\u044c \u043e \u0442\u043e\u043c \u0436\u0435 \u0441\u043e\u0431\u044b\u0442\u0438\u0438 \u2014 \u043e\u0431\u0441\u0447\u0438\u0442\u0430\u0442\u044c \u0430\u043d\u0430\u043b\u0438\u0442\u0438\u043a\u0443, \u043e\u0431\u043d\u043e\u0432\u0438\u0442\u044c \u043f\u043e\u0438\u0441\u043a\u043e\u0432\u044b\u0439 \u0438\u043d\u0434\u0435\u043a\u0441, \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u044c \u043f\u0438\u0441\u044c\u043c\u043e. \u0412\u043e\u0437\u043d\u0438\u043a\u0430\u0435\u0442 \u0441\u043e\u0431\u043b\u0430\u0437\u043d \u043f\u0440\u043e\u0441\u0442\u043e \u0434\u0451\u0440\u043d\u0443\u0442\u044c \u0435\u0433\u043e \u043f\u043e HTTP, \u0438 \u044d\u0442\u043e \u043f\u0435\u0440\u0432\u0430\u044f \u043e\u0448\u0438\u0431\u043a\u0430, \u043a\u043e\u0442\u043e\u0440\u0443\u044e \u0432\u0441\u0435 \u0441\u043e\u0432\u0435\u0440\u0448\u0430\u044e\u0442 \u0438 \u0432\u0441\u0435 \u0436\u0435 \u0438\u0441\u043f\u0440\u0430\u0432\u043b\u044f\u044e\u0442: \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439 \u0432\u044b\u0437\u043e\u0432 \u0434\u0435\u043b\u0430\u0435\u0442 \u0432\u0430\u0441 \u043d\u0430\u0441\u0442\u043e\u043b\u044c\u043a\u043e \u0436\u0435 \u043d\u0430\u0434\u0451\u0436\u043d\u044b\u043c, \u043d\u0430\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u043d\u0430\u0434\u0451\u0436\u0435\u043d \u0441\u0430\u043c\u044b\u0439 \u0445\u0440\u0443\u043f\u043a\u0438\u0439 \u0438\u0437 \u0432\u0430\u0448\u0438\u0445 \u0441\u043e\u0441\u0435\u0434\u0435\u0439.<\/p>\n<p>\u0417\u043d\u0430\u0447\u0438\u0442 \u043d\u0443\u0436\u043d\u043e \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e, \u0447\u0435\u0440\u0435\u0437 \u0431\u0440\u043e\u043a\u0435\u0440. \u0418 \u043f\u043e\u0447\u0442\u0438 \u0432\u0441\u0435\u0433\u0434\u0430 \u044d\u0442\u0438\u043c \u0431\u0440\u043e\u043a\u0435\u0440\u043e\u043c \u043e\u043a\u0430\u0437\u044b\u0432\u0430\u0435\u0442\u0441\u044f Kafka. \u042d\u0442\u043e \u043d\u0435 \u043a\u0430\u0440\u0433\u043e-\u043a\u0443\u043b\u044c\u0442, \u0430 \u0440\u0430\u0446\u0438\u043e\u043d\u0430\u043b\u044c\u043d\u044b\u0439 \u0432\u044b\u0431\u043e\u0440:<\/p>\n<ul>\n<li>\n<p><strong>80%+ \u043a\u043e\u043c\u043f\u0430\u043d\u0438\u0439 \u0438\u0437 Fortune 100<\/strong> \u0435\u0451 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044e\u0442, \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u0438\u0435 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0438 \u0435\u0441\u0442\u044c \u0434\u043b\u044f \u0432\u0441\u0435\u0445 \u044f\u0437\u044b\u043a\u043e\u0432 (<a href=\"https:\/\/kafka.apache.org\/powered-by\/\" rel=\"noopener nofollow\">kafka.apache.org\/powered-by<\/a>)<\/p>\n<\/li>\n<li>\n<p><strong>\u041f\u0440\u043e\u0432\u0435\u0440\u0435\u043d\u0430 \u0432 \u0431\u043e\u044e<\/strong>: \u0432\u044b\u0440\u043e\u0441\u043b\u0430 \u0438\u0437 LinkedIn, \u0433\u0434\u0435 \u0433\u043e\u043d\u044f\u043b\u0438 \u043c\u0438\u043b\u043b\u0438\u0430\u0440\u0434\u044b \u0441\u043e\u0431\u044b\u0442\u0438\u0439 \u0432 \u0434\u0435\u043d\u044c. Netflix, Uber, Goldman Sachs \u2014 \u0432\u0441\u0435 \u043d\u0430 \u043d\u0435\u0439 (<a href=\"https:\/\/singhajit.com\/distributed-systems\/two-phase-commit\/\" rel=\"noopener nofollow\">\u043f\u043e\u0434\u0440\u043e\u0431\u043d\u0435\u0435 \u043e \u0442\u043e\u043c, \u043a\u0430\u043a Kafka \u0443\u0441\u0442\u0440\u043e\u0435\u043d\u0430 \u0432\u043d\u0443\u0442\u0440\u0438<\/a>)<\/p>\n<\/li>\n<li>\n<p><strong>\u041c\u0430\u0441\u0448\u0442\u0430\u0431\u0438\u0440\u0443\u0435\u0442\u0441\u044f \u043b\u0438\u043d\u0435\u0439\u043d\u043e<\/strong>: \u043f\u0430\u0440\u0442\u0438\u0446\u0438\u0438 + consumer groups, \u0434\u043e\u0431\u0430\u0432\u043b\u044f\u0439 \u0431\u0440\u043e\u043a\u0435\u0440\u043e\u0432 \u0431\u0435\u0437 \u0438\u0437\u043c\u0435\u043d\u0435\u043d\u0438\u044f \u043a\u043e\u0434\u0430<\/p>\n<\/li>\n<li>\n<p><strong>\u0413\u043e\u0442\u043e\u0432\u0430\u044f \u043c\u043e\u0434\u0435\u043b\u044c \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438<\/strong>: pull, \u043f\u0435\u0440\u0441\u0438\u0441\u0442\u0435\u043d\u0442\u043d\u044b\u0439 \u043b\u043e\u0433, \u0440\u0435\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u044f, \u043d\u0430\u0441\u0442\u0440\u0430\u0438\u0432\u0430\u0435\u043c\u043e\u0435 \u0445\u0440\u0430\u043d\u0435\u043d\u0438\u0435<\/p>\n<\/li>\n<li>\n<p><strong>\u0412 \u043a\u043e\u043d\u0446\u0435 \u043a\u043e\u043d\u0446\u043e\u0432 \u044d\u0442\u043e \u043c\u043e\u0434\u043d\u043e<\/strong>.<\/p>\n<\/li>\n<\/ul>\n<p>\u0412 \u043a\u043e\u0434\u0435 \u044d\u0442\u043e \u0432\u044b\u0433\u043b\u044f\u0434\u0438\u0442 \u0442\u0430\u043a:<\/p>\n<pre><code class=\"cs\">db.Messages.Add(msg);await db.SaveChangesAsync(ct);                    \/\/ (1) \u0437\u0430\u043f\u0438\u0441\u0430\u043b\u0438 \u0432 \u0431\u0430\u0437\u0443await producer.ProduceAsync(KafkaConsumer.Topic, new(){    Timestamp = new(msg.CreatedAt),    Key = msg.Id,    Value = msg}, ct);                                            \/\/ (2) \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u043b\u0438 \u0432 Kafka<\/code><div class=\"code-explainer\"><a href=\"https:\/\/sourcecraft.dev\/\" class=\"tm-button code-explainer__link\" style=\"visibility: hidden;\"><img style=\"width:14px;height:14px;object-fit:cover;object-position:left;\"\/><\/a><\/div><\/pre>\n<p>\u0421\u043f\u0440\u043e\u0441\u0438\u0442\u0435 \u0441\u0435\u0431\u044f: \u0447\u0442\u043e \u0441\u043b\u0443\u0447\u0438\u0442\u0441\u044f, \u0435\u0441\u043b\u0438 \u043f\u0440\u043e\u0446\u0435\u0441\u0441 \u0443\u043f\u0430\u0434\u0451\u0442 \u043c\u0435\u0436\u0434\u0443 \u0441\u0442\u0440\u043e\u043a\u043e\u0439 (1) \u0438 \u0441\u0442\u0440\u043e\u043a\u043e\u0439 (2)? \u0412 \u0431\u0430\u0437\u0435 \u2014 \u0437\u0430\u043f\u0438\u0441\u044c \u0435\u0441\u0442\u044c. \u0412 Kafka \u2014 \u043d\u0438\u0447\u0435\u0433\u043e. Downstream-\u0441\u0435\u0440\u0432\u0438\u0441 \u043d\u0438\u043a\u043e\u0433\u0434\u0430 \u043d\u0435 \u0443\u0437\u043d\u0430\u0435\u0442, \u0447\u0442\u043e \u0441\u043e\u0431\u044b\u0442\u0438\u0435 \u043f\u0440\u043e\u0438\u0437\u043e\u0448\u043b\u043e.<\/p>\n<figure class=\"\"><img decoding=\"async\" src=\"https:\/\/habrastorage.org\/getpro\/habr\/\/post_images\/1dd\/1f1\/a7d\/1dd1f1a7d1822b922e9f8ccdd5ee7f1c.svg\" alt=\"\u041a\u043b\u0438\u0435\u043d\u0442 \u2192 HTTP POST \u2192 [\u0421\u0435\u0440\u0432\u0438\u0441] \u2192 INSERT \u2192 Postgres \u2192 HTTP 201\" title=\"\u0441\u0445\u0435\u043c\u0430 1\" sizes=\"(max-width: 780px) 100vw, 50vw\" srcset=\"https:\/\/habrastorage.org\/getpro\/habr\/\/post_images\/1dd\/1f1\/a7d\/1dd1f1a7d1822b922e9f8ccdd5ee7f1c.svg 780w,&#10;       https:\/\/habrastorage.org\/getpro\/habr\/\/post_images\/1dd\/1f1\/a7d\/1dd1f1a7d1822b922e9f8ccdd5ee7f1c.svg 781w\" loading=\"lazy\" decode=\"async\"\/><\/p>\n<div><figcaption>\u0441\u0445\u0435\u043c\u0430 1<\/figcaption><\/div>\n<\/figure>\n<p>\u0418 \u044d\u0442\u043e \u043d\u0435 \u044d\u043a\u0437\u043e\u0442\u0438\u043a\u0430 \u043d\u0430 0.001% \u0438\u043d\u0446\u0438\u0434\u0435\u043d\u0442\u043e\u0432. <code>CancellationToken<\/code> \u043f\u043e \u0437\u0430\u043a\u0440\u044b\u0442\u0438\u044e \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f \u043a\u043b\u0438\u0435\u043d\u0442\u0430 \u2014 \u0442\u0430\u0439\u043c\u0430\u0443\u0442, \u0437\u0430\u043a\u0440\u044b\u0442\u0438\u0435 \u0438\u043b\u0438 \u043e\u0431\u043d\u043e\u0432\u043b\u0435\u043d\u0438\u0435 \u0441\u0442\u0440\u0430\u043d\u0438\u0446\u044b, \u043a\u0440\u043e\u043c\u0435 \u0442\u043e\u0433\u043e \u0441\u043b\u0443\u0447\u0430\u0435\u0442\u0441\u044f \u0440\u0435\u0441\u0442\u0430\u0440\u0442 \u043f\u043e\u0434\u0430, \u0434\u0435\u043f\u043b\u043e\u0439, OOM-killer, \u0434\u0430 \u043f\u0440\u043e\u0441\u0442\u043e \u0438\u0441\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0435 \u0432\u043d\u0443\u0442\u0440\u0438 <code>ProduceAsync<\/code> \u2014 \u043b\u044e\u0431\u043e\u0435 \u0438\u0437 \u044d\u0442\u043e\u0433\u043e \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u043e \u0441\u043e\u0437\u0434\u0430\u0451\u0442 \u0434\u044b\u0440\u0443.<\/p>\n<p>\u042d\u0442\u043e <strong>dual write problem<\/strong>: \u0434\u0432\u0430 \u043d\u0435\u0437\u0430\u0432\u0438\u0441\u0438\u043c\u044b\u0445 \u0440\u0435\u0441\u0443\u0440\u0441\u0430 \u043e\u0431\u043d\u043e\u0432\u043b\u044f\u044e\u0442\u0441\u044f \u043d\u0435 \u0430\u0442\u043e\u043c\u0430\u0440\u043d\u043e. \u041d\u0435\u043b\u044c\u0437\u044f \u043e\u0431\u0435\u0440\u043d\u0443\u0442\u044c <code>INSERT<\/code> \u0432 Postgres \u0438 <code>ProduceAsync<\/code> \u0432 Kafka \u0432 \u043e\u0434\u043d\u0443 \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u044e. \u041e\u043d\u0438 \u043f\u0440\u043e\u0441\u0442\u043e \u043d\u0435 \u0437\u043d\u0430\u044e\u0442 \u0434\u0440\u0443\u0433 \u043e \u0434\u0440\u0443\u0433\u0435.<\/p>\n<p>\u0414\u0435\u043b\u0430\u0442\u044c \u0437\u0430\u043f\u0438\u0441\u044c \u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0443 \u0432 \u043e\u0431\u0440\u0430\u0442\u043d\u043e\u043c \u043f\u043e\u0440\u044f\u0434\u043a\u0435 &#8212; \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u0442\u0441\u044f \u0435\u0449\u0435 \u0445\u0443\u0436\u0435.<\/p>\n<p>\u00ab\u041f\u0440\u043e\u0441\u0442\u043e \u0440\u0435\u0442\u0440\u0430\u0438\u0442\u044c\u00bb \u043d\u0435 \u043f\u043e\u043c\u043e\u0433\u0430\u0435\u0442:<\/p>\n<ul>\n<li>\n<p>\u0421\u0435\u0440\u0432\u0438\u0441 \u043f\u0430\u0434\u0430\u0435\u0442 \u0434\u043e \u0440\u0435\u0442\u0440\u0430\u044f \u2192 \u0441\u043e\u0431\u044b\u0442\u0438\u0435 \u043f\u043e\u0442\u0435\u0440\u044f\u043d\u043e<\/p>\n<\/li>\n<li>\n<p>\u0420\u0435\u0442\u0440\u0430\u0439 \u043f\u0440\u043e\u0445\u043e\u0434\u0438\u0442, \u043d\u043e \u0438 \u043e\u0440\u0438\u0433\u0438\u043d\u0430\u043b \u043f\u0440\u043e\u0448\u0451\u043b \u2192 \u0434\u0443\u0431\u043b\u0438\u043a\u0430\u0442<\/p>\n<\/li>\n<li>\n<p>\u0420\u0435\u0442\u0440\u0430\u0438\u043c \u0438 \u0431\u0430\u0437\u0443 \u0442\u043e\u0436\u0435 \u2192 \u0434\u0443\u0431\u043b\u0438\u043a\u0430\u0442 \u0437\u0430\u043a\u0430\u0437\u0430<\/p>\n<\/li>\n<\/ul>\n<h2>\u0413\u043b\u0430\u0432\u0430 3. \u0413\u0430\u0440\u0430\u043d\u0442\u0438\u044f \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0438<\/h2>\n<p>\u041c\u043e\u0436\u0435\u0442, \u0440\u0430\u0441\u043f\u0440\u0435\u0434\u0435\u043b\u0451\u043d\u043d\u0430\u044f \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u044f? 2PC? <a href=\"https:\/\/singhajit.com\/distributed-systems\/two-phase-commit\/\" rel=\"noopener nofollow\">\u041a \u0441\u043e\u0436\u0430\u043b\u0435\u043d\u0438\u044e \u043d\u0435\u0442<\/a>:<\/p>\n<ul>\n<li>\n<p>Kafka \u043d\u0435 \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u0438\u0432\u0430\u0435\u0442 XA. RabbitMQ \u043d\u0435 \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u0438\u0432\u0430\u0435\u0442. SQS \u043d\u0435 \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u0438\u0432\u0430\u0435\u0442.<\/p>\n<\/li>\n<li>\n<p>2PC <strong>\u0431\u043b\u043e\u043a\u0438\u0440\u0443\u044e\u0449\u0438\u0439<\/strong>: \u043a\u043e\u043e\u0440\u0434\u0438\u043d\u0430\u0442\u043e\u0440 \u043f\u0430\u0434\u0430\u0435\u0442 \u2192 \u0443\u0447\u0430\u0441\u0442\u043d\u0438\u043a\u0438 \u0432\u0438\u0441\u044f\u0442 \u0441 \u043b\u043e\u043a\u0430\u043c\u0438 \u0431\u0435\u0441\u043a\u043e\u043d\u0435\u0447\u043d\u043e<\/p>\n<\/li>\n<li>\n<p>30\u201340% \u043f\u043e\u0442\u0435\u0440\u0438 \u043f\u0440\u043e\u043f\u0443\u0441\u043a\u043d\u043e\u0439 \u0441\u043f\u043e\u0441\u043e\u0431\u043d\u043e\u0441\u0442\u0438 \u043f\u043e \u0441\u0440\u0430\u0432\u043d\u0435\u043d\u0438\u044e \u0441 \u043b\u043e\u043a\u0430\u043b\u044c\u043d\u044b\u043c\u0438 \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u044f\u043c\u0438<\/p>\n<\/li>\n<li>\n<p>\u0422\u0440\u0435\u0431\u0443\u0435\u0442, \u0447\u0442\u043e\u0431\u044b <strong>\u0432\u0441\u0435<\/strong> \u0443\u0447\u0430\u0441\u0442\u043d\u0438\u043a\u0438 \u0431\u044b\u043b\u0438 \u0434\u043e\u0441\u0442\u0443\u043f\u043d\u044b \u043e\u0434\u043d\u043e\u0432\u0440\u0435\u043c\u0435\u043d\u043d\u043e<\/p>\n<\/li>\n<\/ul>\n<p>\u0412\u043e\u0442 \u043a \u0447\u0435\u043c\u0443 \u043c\u044b \u043d\u0430 \u0441\u0430\u043c\u043e\u043c \u0434\u0435\u043b\u0435 \u043f\u0440\u0438\u0448\u043b\u0438: \u0435\u0441\u043b\u0438 \u0432\u044b \u043f\u0438\u0448\u0435\u0442\u0435 \u0432 Kafka \u043d\u0430\u043f\u0440\u044f\u043c\u0443\u044e \u0438\u0437 \u0431\u0438\u0437\u043d\u0435\u0441-\u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u0438 \u2014 \u0432\u044b \u0443\u0436\u0435 \u043d\u0430\u0440\u0443\u0448\u0430\u0435\u0442\u0435 \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u0438. \u0421\u043f\u043e\u0440\u0438\u0442\u044c \u0441 \u044d\u0442\u0438\u043c \u0431\u0435\u0441\u0441\u043c\u044b\u0441\u043b\u0435\u043d\u043d\u043e \u2014 \u043c\u043e\u0436\u043d\u043e \u0442\u043e\u043b\u044c\u043a\u043e \u043b\u0438\u0431\u043e \u043f\u0440\u0438\u043d\u044f\u0442\u044c outbox, \u043b\u0438\u0431\u043e \u0436\u0438\u0442\u044c \u0441 \u043f\u043e\u0442\u0435\u0440\u044f\u043d\u043d\u044b\u043c\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f\u043c\u0438.<\/p>\n<p>\u041d\u0430 \u043f\u043e\u043c\u043e\u0449\u044c \u043f\u0440\u0438\u0445\u043e\u0434\u0438\u0442 \u043f\u0430\u0442\u0442\u0435\u0440\u043d <a href=\"https:\/\/singhajit.com\/transactional-outbox-pattern\/\" rel=\"noopener nofollow\"><strong>Transactional Outbox<\/strong><\/a>.<\/p>\n<ul>\n<li>\n<p>\u0415\u0433\u043e \u043d\u0430\u0437\u044b\u0432\u0430\u044e\u0442 \u00ab\u043a\u0430\u043d\u043e\u043d\u0438\u0447\u0435\u0441\u043a\u0438\u043c \u0440\u0435\u0448\u0435\u043d\u0438\u0435\u043c\u00bb \u0434\u043b\u044f \u043d\u0430\u0434\u0451\u0436\u043d\u043e\u0439 \u043f\u0443\u0431\u043b\u0438\u043a\u0430\u0446\u0438\u0438 \u0441\u043e\u0431\u044b\u0442\u0438\u0439 \u2014 \u0444\u043e\u0440\u043c\u0443\u043b\u0438\u0440\u043e\u0432\u043a\u0430 \u0438\u0437 \u0440\u0430\u0437\u0431\u043e\u0440\u0430 \u0443 <a href=\"https:\/\/microservices.io\/patterns\/data\/transactional-outbox.html\" rel=\"noopener nofollow\">Chris Richardson, microservices.io<\/a>.<\/p>\n<\/li>\n<li>\n<p><a href=\"https:\/\/docs.aws.amazon.com\/prescriptive-guidance\/latest\/cloud-design-patterns\/transactional-outbox.html\" rel=\"noopener nofollow\">AWS Prescriptive Guidance<\/a> \u0440\u0435\u043a\u043e\u043c\u0435\u043d\u0434\u0443\u0435\u0442 \u0438\u043c\u0435\u043d\u043d\u043e \u0435\u0433\u043e.<\/p>\n<\/li>\n<li>\n<p><a href=\"https:\/\/developer.confluent.io\/courses\/microservices\/the-transactional-outbox-pattern\/\" rel=\"noopener nofollow\">Confluent<\/a> \u0432\u043a\u043b\u044e\u0447\u0430\u0435\u0442 outbox \u043a\u0430\u043a \u043e\u0431\u044f\u0437\u0430\u0442\u0435\u043b\u044c\u043d\u044b\u0439 \u0448\u0430\u0433 \u0432 \u0441\u043e\u0431\u0441\u0442\u0432\u0435\u043d\u043d\u044b\u0439 \u043a\u0443\u0440\u0441 \u043f\u043e \u043c\u0438\u043a\u0440\u043e\u0441\u0435\u0440\u0432\u0438\u0441\u0430\u043c.<\/p>\n<\/li>\n<\/ul>\n<p>\u0418\u0434\u0435\u044f \u043f\u0440\u043e\u0441\u0442\u0430\u044f \u0434\u043e \u0433\u0435\u043d\u0438\u0430\u043b\u044c\u043d\u043e\u0441\u0442\u0438: \u0437\u0430\u043f\u0438\u0441\u0430\u0442\u044c \u0438 \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442 \u0440\u0430\u0431\u043e\u0442\u044b, \u0438 \u043d\u0430\u043c\u0435\u0440\u0435\u043d\u0438\u0435 \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u044c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 <strong>\u0432 \u043e\u0434\u043d\u043e\u0439 \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u0438<\/strong>. \u041e\u0431\u0435 \u0442\u0430\u0431\u043b\u0438\u0446\u044b \u2014 \u0432 \u043e\u0434\u043d\u043e\u0439 \u0431\u0430\u0437\u0435. \u041e\u0434\u043d\u0430 ACID-\u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u044f. \u041b\u0438\u0431\u043e \u043e\u0431\u0435 \u0437\u0430\u043f\u0438\u0441\u0438 \u0437\u0430\u043a\u043e\u043c\u043c\u0438\u0447\u0435\u043d\u044b, \u043b\u0438\u0431\u043e \u043e\u0431\u0435 \u043e\u0442\u043a\u0430\u0447\u0435\u043d\u044b.<\/p>\n<p>\u0412\u0430\u043c \u043d\u0435 \u043d\u0443\u0436\u043d\u043e \u043f\u0438\u0441\u0430\u0442\u044c \u0434\u0438\u0441\u043f\u0435\u0442\u0447\u0435\u0440 outbox \u0438 \u0442\u0430\u0431\u043b\u0438\u0446\u0443 \u0440\u0443\u043a\u0430\u043c\u0438. \u041e\u043d\u043e \u0443\u0436\u0435 \u0434\u0430\u0432\u043d\u043e \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043d\u043e \u0432 \u0441\u043e\u0442\u043d\u044f\u0445 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a. \u041d\u0430\u043f\u0440\u0438\u043c\u0435\u0440 <code>ZeroAlloc.Outbox<\/code>. \u0412\u0441\u0451, \u0447\u0442\u043e \u043e\u0442 \u0432\u0430\u0441 \u0442\u0440\u0435\u0431\u0443\u0435\u0442\u0441\u044f \u2014 \u044d\u0442\u043e \u0437\u0430\u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0441\u0435\u0440\u0432\u0438\u0441\u044b \u0432 DI \u0438 \u043d\u0430\u043f\u0438\u0441\u0430\u0442\u044c \u043a\u0440\u043e\u0448\u0435\u0447\u043d\u044b\u0439 \u043a\u043b\u0430\u0441\u0441-\u0430\u0434\u0430\u043f\u0442\u0435\u0440 \u0434\u043b\u044f \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0438 \u0432 Kafka.<\/p>\n<p>\u0412\u043e\u0442 \u043a\u0430\u043a \u0432\u044b\u0433\u043b\u044f\u0434\u0438\u0442 \u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0430 \u0432 <code>Program.cs<\/code>:<\/p>\n<pre><code class=\"cs\">\/\/ 1. \u0420\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u0443\u0435\u043c \u0441\u0430\u043c Outbox \u0438\u0437 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0438 ZeroAlloc.Outboxbuilder.Services.AddOutbox(options =&gt;{    options.PollingInterval = TimeSpan.FromMilliseconds(100); \/\/ \u0414\u043b\u044f \u0442\u0435\u0441\u0442\u043e\u0432    options.BatchSize = 50;    options.MaxAttempts = 3;}).WithEfCore&lt;AppDbContext&gt;().AddMessageOutbox();\/\/ 2. \u0420\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u0443\u0435\u043c \u043d\u0430\u0448 \u0430\u0434\u0430\u043f\u0442\u0435\u0440, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043f\u0440\u043e\u0441\u0442\u043e \u0434\u0435\u0440\u0433\u0430\u0435\u0442 Kafkabuilder.Services.AddTransient&lt;IOutboxDispatcher&lt;Message&gt;, OutboxDispatcher&gt;();<\/code><div class=\"code-explainer\"><a href=\"https:\/\/sourcecraft.dev\/\" class=\"tm-button code-explainer__link\" style=\"visibility: hidden;\"><img style=\"width:14px;height:14px;object-fit:cover;object-position:left;\"\/><\/a><\/div><\/pre>\n<p>\u0418 \u0441\u0430\u043c \u0430\u0434\u0430\u043f\u0442\u0435\u0440 \u2014 5 \u0441\u0442\u0440\u043e\u043a \u043a\u043e\u0434\u0430, \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0430 \u0441\u0430\u043c\u0430 \u0431\u0435\u0440\u0435\u0442 \u043d\u0430 \u0441\u0435\u0431\u044f \u0444\u043e\u043d\u043e\u0432\u044b\u0439 \u043e\u043f\u0440\u043e\u0441, \u0431\u0430\u0442\u0447\u0438\u043d\u0433, \u0440\u0435\u0442\u0440\u0430\u0438 \u0438 \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u043e\u043d\u043d\u043e\u0441\u0442\u044c:<\/p>\n<pre><code class=\"cs\">public class OutboxDispatcher(IProducer&lt;int, Message&gt; producer) : IOutboxDispatcher&lt;Message&gt;{    public async ValueTask DispatchAsync(Message message, CancellationToken ct)    =&gt; await producer.ProduceAsync(KafkaConsumer.Topic, new()    {        Timestamp = new(message.CreatedAt),        Key = message.Id,        Value = message    }, ct);}<\/code><div class=\"code-explainer\"><a href=\"https:\/\/sourcecraft.dev\/\" class=\"tm-button code-explainer__link\" style=\"visibility: hidden;\"><img style=\"width:14px;height:14px;object-fit:cover;object-position:left;\"\/><\/a><\/div><\/pre>\n<p>\u0412 \u043a\u043e\u0434\u0435 \u044d\u043d\u0434\u043f\u043e\u0438\u043d\u0442\u0430 \u043c\u044b \u043f\u0440\u043e\u0441\u0442\u043e \u0438\u043d\u0436\u0435\u043a\u0442\u0438\u043c <code>IOutboxWriter&lt;Message&gt;<\/code> \u0438 \u043f\u0438\u0448\u0435\u043c \u0432 \u0442\u043e\u0439 \u0436\u0435 \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u0438:<\/p>\n<pre><code class=\"cs\">app.MapPost(\"\/outbox\", async (Message dto, AppDbContext db, IOutboxWriter&lt;Message&gt; outbox, ...) =&gt;{    var id = await db.Database.CreateExecutionStrategy().ExecuteInTransactionAsync(async (ct) =&gt;    {        Message msg = new() { Content = dto.Content, CreatedAt = DateTime.UtcNow };        db.Messages.Add(msg);        await db.SaveChangesAsync(ct);                \/\/ \u2190 \u041f\u0438\u0448\u0435\u043c \u0432 outbox \u0432 \u0422\u041e\u0419 \u0416\u0415 \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u0438. ZeroAlloc.Outbox \u0441\u0430\u043c \u0432\u0441\u0451 \u0441\u043e\u0445\u0440\u0430\u043d\u0438\u0442        await outbox.WriteAsync(msg, ct: ct);              return msg.Id;    }, ct =&gt; Task.FromResult(false), ct);    ...});<\/code><div class=\"code-explainer\"><a href=\"https:\/\/sourcecraft.dev\/\" class=\"tm-button code-explainer__link\" style=\"visibility: hidden;\"><img style=\"width:14px;height:14px;object-fit:cover;object-position:left;\"\/><\/a><\/div><\/pre>\n<figure class=\"\"><img decoding=\"async\" src=\"https:\/\/habrastorage.org\/getpro\/habr\/\/post_images\/9df\/31e\/ff3\/9df31eff3c07db3fd6142510fbbce4c0.svg\" alt=\"Postgres (WAL) \u2192 Debezium (Kafka Connect) \u2192 Kafka topic \u2192 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440(\u044b)\" title=\"\u0441\u0445\u0435\u043c\u0430 2\" sizes=\"(max-width: 780px) 100vw, 50vw\" srcset=\"https:\/\/habrastorage.org\/getpro\/habr\/\/post_images\/9df\/31e\/ff3\/9df31eff3c07db3fd6142510fbbce4c0.svg 780w,&#10;       https:\/\/habrastorage.org\/getpro\/habr\/\/post_images\/9df\/31e\/ff3\/9df31eff3c07db3fd6142510fbbce4c0.svg 781w\" loading=\"lazy\" decode=\"async\"\/><\/p>\n<div><figcaption>\u0441\u0445\u0435\u043c\u0430 2<\/figcaption><\/div>\n<\/figure>\n<p>\u041f\u0440\u043e\u0431\u043b\u0435\u043c\u0430 dual write \u0440\u0435\u0448\u0435\u043d\u0430. \u041d\u043e \u0432\u0437\u0430\u043c\u0435\u043d \u043c\u044b \u043f\u043e\u043b\u0443\u0447\u0438\u043b\u0438 \u043d\u043e\u0432\u0443\u044e.<\/p>\n<h3>\u0426\u0435\u043d\u0430 \u0430\u0442\u043e\u043c\u0430\u0440\u043d\u043e\u0441\u0442\u0438<\/h3>\n<div>\n<div class=\"table\">\n<table>\n<tbody>\n<tr>\n<th>\n<p align=\"left\">\u0426\u0435\u043d\u0430<\/p>\n<\/th>\n<th>\n<p align=\"left\">\u0421\u0443\u0442\u044c<\/p>\n<\/th>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">Write amplification<\/p>\n<\/td>\n<td>\n<p align=\"left\"><code>INSERT<\/code> + <code>INSERT<\/code> + <code>UPDATE<\/code> \u043d\u0430 \u043a\u0430\u0436\u0434\u043e\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">Vacuum<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u041f\u043e\u0441\u0442\u043e\u044f\u043d\u043d\u043e \u043e\u0431\u043d\u043e\u0432\u043b\u044f\u0435\u043c\u0430\u044f outbox-\u0442\u0430\u0431\u043b\u0438\u0446\u0430 \u0433\u0435\u043d\u0435\u0440\u0438\u0440\u0443\u0435\u0442 \u043c\u0451\u0440\u0442\u0432\u044b\u0435 \u043a\u043e\u0440\u0442\u0435\u0436\u0438<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">\u0424\u043e\u043d\u043e\u0432\u044b\u0439 \u0434\u0438\u0441\u043f\u0435\u0442\u0447\u0435\u0440<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0415\u0449\u0451 \u043e\u0434\u0438\u043d \u043f\u0440\u043e\u0446\u0435\u0441\u0441, \u043a\u043e\u043d\u043a\u0443\u0440\u0438\u0440\u0443\u044e\u0449\u0438\u0439 \u0437\u0430 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f \u043a Postgres<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">\u0417\u0430\u0434\u0435\u0440\u0436\u043a\u0430<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0418\u043d\u0442\u0435\u0440\u0432\u0430\u043b \u043e\u043f\u0440\u043e\u0441\u0430. \u041d\u0435 \u043c\u0438\u043b\u043b\u0438\u0441\u0435\u043a\u0443\u043d\u0434\u044b. \u0421\u043e\u0442\u043d\u0438 \u043c\u0438\u043b\u043b\u0438\u0441\u0435\u043a\u0443\u043d\u0434.<\/p>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n<p>\u0418 \u0433\u043b\u0430\u0432\u043d\u043e\u0435 \u2014 \u0432\u0441\u044f \u044d\u0442\u0430 \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0430 \u0436\u0438\u0432\u0451\u0442 <strong>\u0432\u043d\u0443\u0442\u0440\u0438 \u0442\u043e\u0433\u043e \u0436\u0435 \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u0430 \u0438 \u0442\u043e\u0439 \u0436\u0435 \u0431\u0430\u0437\u044b<\/strong>, \u0447\u0442\u043e \u043e\u0431\u0441\u043b\u0443\u0436\u0438\u0432\u0430\u0435\u0442 \u0431\u0438\u0437\u043d\u0435\u0441-\u043b\u043e\u0433\u0438\u043a\u0443. \u0427\u0430\u0441\u0442\u044b\u0439 \u043f\u043e\u043b\u043b\u0438\u043d\u0433 \u0441\u043e\u0437\u0434\u0430\u0451\u0442 \u043f\u043e\u0441\u0442\u043e\u044f\u043d\u043d\u044b\u0439 \u0444\u043e\u043d\u043e\u0432\u044b\u0439 I\/O \u0434\u0430\u0436\u0435 \u0442\u043e\u0433\u0434\u0430, \u043a\u043e\u0433\u0434\u0430 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u043d\u0435\u0442.<\/p>\n<h2>\u0413\u043b\u0430\u0432\u0430 4. Debezium. \u0412\u044b\u043d\u043e\u0441\u0438\u043c \u0431\u043e\u043b\u044c \u0437\u0430 \u043f\u0440\u0435\u0434\u0435\u043b\u044b \u0441\u0435\u0440\u0432\u0438\u0441\u0430<\/h2>\n<p>\u0412\u0441\u044e \u044d\u0442\u0443 \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0443 \u043d\u0435 \u043e\u0431\u044f\u0437\u0430\u0442\u0435\u043b\u044c\u043d\u043e \u0434\u0435\u0440\u0436\u0430\u0442\u044c \u0432 \u0442\u043e\u043c \u0436\u0435 \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u0435 \u0438 \u043f\u043e\u0441\u0442\u043e\u044f\u043d\u043d\u043e \u0434\u0435\u0440\u0433\u0430\u0442\u044c \u0431\u0430\u0437\u0443. Postgres \u0438 \u0442\u0430\u043a \u043f\u0438\u0448\u0435\u0442 \u043a\u0430\u0436\u0434\u043e\u0435 \u0438\u0437\u043c\u0435\u043d\u0435\u043d\u0438\u0435 \u0432 WAL (Write-Ahead Log).  <a href=\"https:\/\/debezium.io\/\" rel=\"noopener nofollow\">Debezium<\/a> \u2014 \u044d\u0442\u043e Kafka Connect \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0440, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0447\u0438\u0442\u0430\u0435\u0442 WAL \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e  \u043b\u043e\u0433\u0438\u0447\u0435\u0441\u043a\u043e\u0439 \u0440\u0435\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u0438 \u0438 \u043f\u0443\u0431\u043b\u0438\u043a\u0443\u0435\u0442 \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442 \u0432 Kafka-\u0442\u043e\u043f\u0438\u043a. \u041f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0435 \u0434\u0435\u043b\u0430\u0435\u0442 \u0442\u043e\u043b\u044c\u043a\u043e <code>INSERT<\/code>. Outbox \u043d\u0435 \u043d\u0443\u0436\u0435\u043d. \u0412\u0441\u044e \u0440\u0430\u0431\u043e\u0442\u0443 \u043f\u043e \u043d\u0430\u0434\u0451\u0436\u043d\u043e\u0439 \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0435 \u0431\u0435\u0440\u0451\u0442 \u043d\u0430 \u0441\u0435\u0431\u044f \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u044b\u0439 \u043f\u0440\u043e\u0446\u0435\u0441\u0441.<\/p>\n<figure class=\"\"><img decoding=\"async\" src=\"https:\/\/habrastorage.org\/getpro\/habr\/\/post_images\/ead\/352\/794\/ead3527946172cd03c9a32c982cadbbf.svg\" alt=\"Postgres (WAL) \u2192 Debezium (Kafka Connect) \u2192 Kafka topic \u2192 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440(\u044b)\" title=\"\u0441\u0445\u0435\u043c\u0430 3\" sizes=\"(max-width: 780px) 100vw, 50vw\" srcset=\"https:\/\/habrastorage.org\/getpro\/habr\/\/post_images\/ead\/352\/794\/ead3527946172cd03c9a32c982cadbbf.svg 780w,&#10;       https:\/\/habrastorage.org\/getpro\/habr\/\/post_images\/ead\/352\/794\/ead3527946172cd03c9a32c982cadbbf.svg 781w\" loading=\"lazy\" decode=\"async\"\/><\/p>\n<div><figcaption>\u0441\u0445\u0435\u043c\u0430 3<\/figcaption><\/div>\n<\/figure>\n<p>\u041e\u043f\u0440\u043e\u0441 \u0441\u043e\u043e\u0431\u0449\u0435\u0441\u0442\u0432\u0430 Debezium 2026 \u0433\u043e\u0434\u0430 \u043f\u043e\u043a\u0430\u0437\u0430\u043b, \u0447\u0442\u043e <strong>91.3% \u0440\u0435\u0441\u043f\u043e\u043d\u0434\u0435\u043d\u0442\u043e\u0432<\/strong> \u0443\u0436\u0435 \u0430\u043a\u0442\u0438\u0432\u043d\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044e\u0442 \u0435\u0433\u043e \u0432 \u043f\u0440\u043e\u0434\u0435 (<a href=\"https:\/\/debezium.io\/blog\/2026\/04\/27\/debezium-2026-survey-results\/\" rel=\"noopener nofollow\">\u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u044b \u043e\u043f\u0440\u043e\u0441\u0430<\/a>), \u0430 <a href=\"https:\/\/debezium.io\/community\/users\/\" rel=\"noopener nofollow\">\u0441\u043f\u0438\u0441\u043e\u043a \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u0435\u0439<\/a> \u0432\u043a\u043b\u044e\u0447\u0430\u0435\u0442 \u043e\u0440\u0433\u0430\u043d\u0438\u0437\u0430\u0446\u0438\u0438 \u0440\u0430\u0437\u043d\u043e\u0433\u043e \u043c\u0430\u0441\u0448\u0442\u0430\u0431\u0430. \u0412\u044b\u0433\u043b\u044f\u0434\u0438\u0442 \u0442\u0430\u043a, \u0447\u0442\u043e \u0440\u0435\u0448\u0435\u043d\u0438\u044e \u043c\u043e\u0436\u043d\u043e \u0434\u043e\u0432\u0435\u0440\u044f\u0442\u044c.<\/p>\n<p>\u041a\u043e\u043d\u0444\u0438\u0433\u0443\u0440\u0430\u0446\u0438\u044f \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0440\u0430:<\/p>\n<pre><code class=\"json\">{  \"config\": {    \"connector.class\": \"io.debezium.connector.postgresql.PostgresConnector\",    \"table.include.list\": \"public.messages\",    \"plugin.name\": \"pgoutput\",    \"slot.name\": \"debezium_slot\",    \"publication.name\": \"debezium_publication\",    \"slot.drop.on.stop\": \"true\",    \"snapshot.mode\": \"no_data\",    \"poll.interval.ms\": \"100\"  }}<\/code><div class=\"code-explainer\"><a href=\"https:\/\/sourcecraft.dev\/\" class=\"tm-button code-explainer__link\" style=\"visibility: hidden;\"><img style=\"width:14px;height:14px;object-fit:cover;object-position:left;\"\/><\/a><\/div><\/pre>\n<p>\u0412\u0430\u0436\u043d\u044b\u0435 \u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0438:<\/p>\n<ul>\n<li>\n<p><code><strong>slot.drop.on.stop: true<\/strong><\/code> \u2014 \u0431\u0435\u0437 \u044d\u0442\u043e\u0433\u043e \u043f\u0440\u0438 \u0443\u0434\u0430\u043b\u0435\u043d\u0438\u0438 \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0440\u0430 \u0441\u043b\u043e\u0442 \u043e\u0441\u0442\u0430\u043d\u0435\u0442\u0441\u044f \u0432\u0438\u0441\u0435\u0442\u044c \u0438 \u0431\u0443\u0434\u0435\u0442 \u043a\u043e\u043f\u0438\u0442\u044c WAL, \u043f\u043e\u043a\u0430 \u043d\u0435 \u043a\u043e\u043d\u0447\u0438\u0442\u0441\u044f \u0434\u0438\u0441\u043a. <a href=\"https:\/\/singhajit.com\/debezium-outbox-postgres-database-impact\/\" rel=\"noopener nofollow\">\u041f\u043e\u0434\u0440\u043e\u0431\u043d\u0435\u0435 \u043e \u0442\u043e\u043c, \u043a\u0430\u043a \u043d\u0430\u0441\u0442\u0440\u0430\u0438\u0432\u0430\u0442\u044c \u0440\u0435\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u044e \u0438 \u0430\u0434\u043c\u0438\u043d\u0438\u0441\u0442\u0440\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0441\u043b\u043e\u0442\u044b<\/a>.<\/p>\n<\/li>\n<li>\n<p><code><strong>poll.interval.ms: 100<\/strong><\/code> \u2014 \u043f\u043e \u0443\u043c\u043e\u043b\u0447\u0430\u043d\u0438\u044e 500 \u043c\u0441. \u041d\u0443\u0436\u043d\u043e \u0434\u043b\u044f \u0442\u0435\u0441\u0442\u043e\u0432.<\/p>\n<\/li>\n<\/ul>\n<p>\u041c\u044b \u0440\u0435\u0448\u0438\u043b\u0438 \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u0443 \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438 \u043d\u0430 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0435. \u041c\u044b \u043d\u0435 \u0440\u0435\u0448\u0438\u043b\u0438 \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u0443 \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u0430 \u0434\u0432\u0438\u0436\u0443\u0449\u0438\u0445\u0441\u044f \u0447\u0430\u0441\u0442\u0435\u0439: \u0442\u0435\u043f\u0435\u0440\u044c \u0443 \u043d\u0430\u0441 Postgres, Kafka \u0438 \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u0430\u044f JVM \u0434\u043b\u044f Kafka Connect.<\/p>\n<h2>\u0413\u043b\u0430\u0432\u0430 5. \u0421\u0442\u043e\u043f. \u0410 \u0437\u0430\u0447\u0435\u043c Kafka \u0432 \u044d\u0442\u043e\u0439 \u0441\u0445\u0435\u043c\u0435?<\/h2>\n<p>\u041f\u043e\u0441\u043c\u043e\u0442\u0440\u0438\u0442\u0435 \u0435\u0449\u0451 \u0440\u0430\u0437 \u043d\u0430 \u0434\u0438\u0430\u0433\u0440\u0430\u043c\u043c\u0443 \u0433\u043b\u0430\u0432\u044b 4. Debezium \u0447\u0438\u0442\u0430\u0435\u0442 WAL, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 Postgres \u043f\u0438\u0448\u0435\u0442 \u0432 \u043b\u044e\u0431\u043e\u043c \u0441\u043b\u0443\u0447\u0430\u0435. \u0415\u0434\u0438\u043d\u0441\u0442\u0432\u0435\u043d\u043d\u043e\u0435, \u0447\u0442\u043e \u0440\u0435\u0430\u043b\u044c\u043d\u043e \u0434\u0435\u043b\u0430\u0435\u0442 Kafka \u0432 \u044d\u0442\u043e\u0439 \u043a\u043e\u043d\u043a\u0440\u0435\u0442\u043d\u043e\u0439 \u0441\u0445\u0435\u043c\u0435 \u2014 \u044d\u0442\u043e \u0440\u0435\u0442\u0440\u0430\u043d\u0441\u043b\u0438\u0440\u0443\u0435\u0442 \u0442\u043e, \u0447\u0442\u043e \u0443\u0436\u0435 \u043b\u0435\u0436\u0438\u0442 \u0432 WAL, \u0435\u0449\u0451 \u0447\u0435\u0440\u0435\u0437 \u043e\u0434\u0438\u043d \u0441\u0435\u0442\u0435\u0432\u043e\u0439 \u0445\u043e\u043f.<\/p>\n<p>WAL \u2014 \u044d\u0442\u043e \u043f\u043e\u0441\u043b\u0435\u0434\u043e\u0432\u0430\u0442\u0435\u043b\u044c\u043d\u044b\u0439, append-only \u043b\u043e\u0433 \u0441 \u043d\u0435\u0437\u0430\u0432\u0438\u0441\u0438\u043c\u044b\u043c\u0438 \u0447\u0438\u0442\u0430\u0442\u0435\u043b\u044f\u043c\u0438, \u043a\u0430\u0436\u0434\u044b\u0439 \u0438\u0437 \u043a\u043e\u0442\u043e\u0440\u044b\u0445 \u0445\u0440\u0430\u043d\u0438\u0442 \u0441\u0432\u043e\u044e \u043f\u043e\u0437\u0438\u0446\u0438\u044e. \u041e\u043f\u0438\u0448\u0438\u0442\u0435 Kafka \u0447\u0435\u043b\u043e\u0432\u0435\u043a\u0443, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043d\u0435 \u0437\u043d\u0430\u0435\u0442, \u0447\u0442\u043e \u044d\u0442\u043e Kafka, \u2014 \u0432\u044b \u0442\u043e\u043b\u044c\u043a\u043e \u0447\u0442\u043e \u043e\u043f\u0438\u0441\u0430\u043b\u0438 WAL.<\/p>\n<div>\n<div class=\"table\">\n<table>\n<tbody>\n<tr>\n<th>\n<p align=\"left\">Kafka<\/p>\n<\/th>\n<th>\n<p align=\"left\">PostgreSQL<\/p>\n<\/th>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">Topic<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0422\u0430\u0431\u043b\u0438\u0446\u0430<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">Partition + \u0444\u0438\u043b\u044c\u0442\u0440<\/p>\n<\/td>\n<td>\n<p align=\"left\">PUBLICATION<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">Consumer + offset<\/p>\n<\/td>\n<td>\n<p align=\"left\">Replication slot<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">Broker<\/p>\n<\/td>\n<td>\n<p align=\"left\">WAL + pgoutput<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">Produce<\/p>\n<\/td>\n<td>\n<p align=\"left\">INSERT<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">Consume<\/p>\n<\/td>\n<td>\n<p align=\"left\">\u0427\u0442\u0435\u043d\u0438\u0435 \u043f\u043e\u0442\u043e\u043a\u0430 \u0440\u0435\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u0438<\/p>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n<p>\u0415\u0441\u043b\u0438 \u043e\u0431\u0430 \u043f\u043e\u0442\u0440\u0435\u0431\u0438\u0442\u0435\u043b\u044f \u0441\u043e\u0431\u044b\u0442\u0438\u044f \u2014 \u0432\u0430\u0448 \u043a\u043e\u0434, \u0442\u043e Kafka \u0432 \u044d\u0442\u043e\u0439 \u0441\u0445\u0435\u043c\u0435 \u2014 \u044d\u0442\u043e \u043f\u043b\u0430\u0442\u0430 \u0437\u0430 \u0440\u0435\u0442\u0440\u0430\u043d\u0441\u043b\u044f\u0446\u0438\u044e \u0442\u043e\u0433\u043e, \u0447\u0442\u043e \u0443\u0436\u0435 \u0441\u0443\u0449\u0435\u0441\u0442\u0432\u0443\u0435\u0442. <code>INSERT<\/code> \u0443\u0436\u0435 \u043f\u043e\u043f\u0430\u043b \u0432 WAL. \u041e\u0442\u0434\u0435\u043b\u044c\u043d\u043e\u0433\u043e \u00ab\u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u044c \u0432 \u043e\u0447\u0435\u0440\u0435\u0434\u044c\u00bb \u043f\u0440\u043e\u0441\u0442\u043e \u043d\u0435 \u0442\u0440\u0435\u0431\u0443\u0435\u0442\u0441\u044f:<\/p>\n<figure class=\"\"><img decoding=\"async\" src=\"https:\/\/habrastorage.org\/getpro\/habr\/\/post_images\/50f\/48c\/3d1\/50f48c3d1c5af9f69a3c62ded672d69e.svg\" alt=\" \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510 \u2502  BEGIN TRANSACTION                 \u2502 \u2502    INSERT INTO messages (...);     \u2502  \u2190 \u044d\u0442\u043e \u043e\u0434\u043d\u043e\u0432\u0440\u0435\u043c\u0435\u043d\u043d\u043e \u0438 \u0437\u0430\u043f\u0438\u0441\u044c, \u2502  COMMIT                            \u2502     \u0438 \u00ab\u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0430 \u0432 \u043e\u0447\u0435\u0440\u0435\u0434\u044c\u00bb \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518 \u2502 \u25bc  (\u0430\u0432\u0442\u043e\u043c\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0438, \u0447\u0435\u0440\u0435\u0437 WAL) Replication slot \u2192 \u043f\u043e\u0434\u043f\u0438\u0441\u0447\u0438\u043a \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u0442 InsertMessage \" title=\"\u0441\u0445\u0435\u043c\u0430 4\" sizes=\"(max-width: 780px) 100vw, 50vw\" srcset=\"https:\/\/habrastorage.org\/getpro\/habr\/\/post_images\/50f\/48c\/3d1\/50f48c3d1c5af9f69a3c62ded672d69e.svg 780w,&#10;       https:\/\/habrastorage.org\/getpro\/habr\/\/post_images\/50f\/48c\/3d1\/50f48c3d1c5af9f69a3c62ded672d69e.svg 781w\" loading=\"lazy\" decode=\"async\"\/><\/p>\n<div><figcaption>\u0441\u0445\u0435\u043c\u0430 4<\/figcaption><\/div>\n<\/figure>\n<p>\u041d\u043e\u043b\u044c write amplification. \u041d\u043e\u043b\u044c outbox-\u0442\u0430\u0431\u043b\u0438\u0446. \u041d\u0435\u0442 \u0444\u043e\u043d\u043e\u0432\u044b\u0445 \u0434\u0438\u0441\u043f\u0435\u0442\u0447\u0435\u0440\u043e\u0432. \u041d\u0435\u0442 \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u043e\u0439 JVM \u0434\u043b\u044f Kafka Connect.<\/p>\n<h2>\u0413\u043b\u0430\u0432\u0430 6. \u0427\u0438\u0442\u0430\u0435\u043c \u043b\u043e\u0433\u0438\u0447\u0435\u0441\u043a\u0443\u044e \u0440\u0435\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u044e<\/h2>\n<p>\u041d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0430 \u043d\u0430 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 \u0411\u0414, \u043b\u0443\u0447\u0448\u0435 \u043f\u0440\u044f\u043c\u043e \u0432 \u043c\u0438\u0433\u0440\u0430\u0446\u0438\u0438:<\/p>\n<pre><code class=\"sql\">CREATE PUBLICATION rep_pub FOR TABLE messages;SELECT * FROM pg_create_logical_replication_slot('rep_slot', 'pgoutput');<\/code><div class=\"code-explainer\"><a href=\"https:\/\/sourcecraft.dev\/\" class=\"tm-button code-explainer__link\" style=\"visibility: hidden;\"><img style=\"width:14px;height:14px;object-fit:cover;object-position:left;\"\/><\/a><\/div><\/pre>\n<p>\u0414\u043b\u044f \u0447\u0442\u0435\u043d\u0438\u044f \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u043c <code>Npgsql.Replication<\/code> \u2014 \u0447\u0430\u0441\u0442\u044c \u0448\u0442\u0430\u0442\u043d\u043e\u0433\u043e \u0434\u0440\u0430\u0439\u0432\u0435\u0440\u0430. \u041d\u0438\u043a\u0430\u043a\u0438\u0445 \u0441\u0442\u043e\u0440\u043e\u043d\u043d\u0438\u0445 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a:<\/p>\n<pre><code class=\"cs\">await using var conn = new LogicalReplicationConnection(connectionString);await conn.Open(stoppingToken);var slot = new PgOutputReplicationSlot(\"rep_slot\");await foreach (var message in conn.StartReplication(    slot, new PgOutputReplicationOptions(\"rep_pub\", PgOutputProtocolVersion.V4, binary: true),    stoppingToken)){    if (message is InsertMessage insertMessage)    {        Message msg = await ReadMessageAsync(insertMessage, stoppingToken);        completions.Complete(msg.Id, msg);    }    conn.SetReplicationStatus(message.WalEnd);  \/\/ \u043e\u0431\u044f\u0437\u0430\u0442\u0435\u043b\u044c\u043d\u043e!    await conn.SendStatusUpdate(stoppingToken);}<\/code><div class=\"code-explainer\"><a href=\"https:\/\/sourcecraft.dev\/\" class=\"tm-button code-explainer__link\" style=\"visibility: hidden;\"><img style=\"width:14px;height:14px;object-fit:cover;object-position:left;\"\/><\/a><\/div><\/pre>\n<p>\u041f\u0440\u0438\u043c\u0435\u0440 \u0447\u0442\u0435\u043d\u0438\u044f \u043b\u043e\u0433\u0438\u0447\u0435\u0441\u043a\u043e\u0439 \u0440\u0435\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u0438 Postgres \u044f \u0443\u0436\u0435 \u043f\u0440\u0438\u0432\u043e\u0434\u0438\u043b \u0432 \u0441\u0442\u0430\u0442\u044c\u0435 <a href=\"https:\/\/habr.com\/ru\/articles\/1068772\/\" rel=\"noopener nofollow\">\u0412\u0430\u0448 \u043a\u044d\u0448 \u0432 Redis \u043d\u0435\u044d\u0444\u0444\u0435\u043a\u0442\u0438\u0432\u0435\u043d, \u0447\u0442\u043e \u0441 \u044d\u0442\u0438\u043c \u0434\u0435\u043b\u0430\u0442\u044c?<\/a><\/p>\n<p>\u041a\u043e\u0434 \u044d\u043d\u0434\u043f\u043e\u043d\u0438\u0442\u0430:<\/p>\n<pre><code class=\"cs\">app.MapPost(\"\/replication\", async (Message dto, AppDbContext db, ...) =&gt;{    Message msg = new() { Content = dto.Content, CreatedAt = DateTime.UtcNow };    db.Messages.Add(msg);    await db.SaveChangesAsync(ct);    return Results.Created($\"\/messages\/{msg.Id}\", msg);});<\/code><div class=\"code-explainer\"><a href=\"https:\/\/sourcecraft.dev\/\" class=\"tm-button code-explainer__link\" style=\"visibility: hidden;\"><img style=\"width:14px;height:14px;object-fit:cover;object-position:left;\"\/><\/a><\/div><\/pre>\n<figure class=\"\"><img decoding=\"async\" src=\"https:\/\/habrastorage.org\/getpro\/habr\/\/post_images\/003\/dae\/6e4\/003dae6e4ee1239b73d57d0d7f402da9.svg\" alt=\" \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510 \u2502  BEGIN TRANSACTION                 \u2502 \u2502    INSERT INTO messages (...);     \u2502  \u2190 \u044d\u0442\u043e \u043e\u0434\u043d\u043e\u0432\u0440\u0435\u043c\u0435\u043d\u043d\u043e \u0438 \u0437\u0430\u043f\u0438\u0441\u044c, \u2502  COMMIT                            \u2502     \u0438 \u00ab\u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0430 \u0432 \u043e\u0447\u0435\u0440\u0435\u0434\u044c\u00bb \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518 \u2502 \u25bc  (\u0430\u0432\u0442\u043e\u043c\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0438, \u0447\u0435\u0440\u0435\u0437 WAL) Replication slot \u2192 \u043f\u043e\u0434\u043f\u0438\u0441\u0447\u0438\u043a \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u0442 InsertMessage \" title=\"\u0441\u0445\u0435\u043c\u0430 5\" sizes=\"(max-width: 780px) 100vw, 50vw\" srcset=\"https:\/\/habrastorage.org\/getpro\/habr\/\/post_images\/003\/dae\/6e4\/003dae6e4ee1239b73d57d0d7f402da9.svg 780w,&#10;       https:\/\/habrastorage.org\/getpro\/habr\/\/post_images\/003\/dae\/6e4\/003dae6e4ee1239b73d57d0d7f402da9.svg 781w\" loading=\"lazy\" decode=\"async\"\/><\/p>\n<div><figcaption>\u0441\u0445\u0435\u043c\u0430 5<\/figcaption><\/div>\n<\/figure>\n<h2>\u0413\u043b\u0430\u0432\u0430 7. \u0411\u0435\u043d\u0447\u043c\u0430\u0440\u043a<\/h2>\n<p>\u041f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0435 \u0432 Aspire  \u0441 \u044d\u043d\u0434\u043f\u043e\u043d\u0438\u0442\u0430\u043c\u0438, \u043a\u0430\u043a \u0432 \u0441\u0442\u0430\u0442\u044c\u0435. \u041f\u0440\u043e\u0434\u044c\u044e\u0441\u0435\u0440 \u0438 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440 \u0432 \u043e\u0434\u043d\u043e\u043c \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u0435. \u041a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440 \u043f\u0440\u043e\u0441\u0442\u043e \u0441\u0438\u0433\u043d\u0430\u043b\u0438\u0442 \u0432\u044b\u0437\u044b\u0432\u0430\u044e\u0449\u0435\u043c\u0443 \u043f\u043e\u0442\u043e\u043a\u0443, \u0447\u0442\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0430\u043d\u043e. \u041a\u043e\u0434 \u043f\u043e \u0441\u0441\u044b\u043b\u043a\u0435 <a href=\"https:\/\/github.com\/gandjustas\/habr-aspnet-kafka\" rel=\"noopener nofollow\">https:\/\/github.com\/gandjustas\/habr-aspnet-kafka<\/a>.<\/p>\n<p>\u041c\u0435\u0442\u043e\u0434\u0438\u043a\u0430: k6, 250 \u0432\u0438\u0440\u0442\u0443\u0430\u043b\u044c\u043d\u044b\u0445 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u0435\u0439, \u043a\u0430\u0436\u0434\u044b\u0439 \u0437\u0430\u043f\u0440\u043e\u0441 \u0436\u0434\u0451\u0442 \u0440\u0435\u0430\u043b\u044c\u043d\u043e\u0433\u043e \u043f\u043e\u0434\u0442\u0432\u0435\u0440\u0436\u0434\u0435\u043d\u0438\u044f \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438. \u0416\u0435\u043b\u0435\u0437\u043e \u2014 Intel i9-9900KF, 64 \u0413\u0411 RAM, \u0432\u0441\u044f \u0438\u043d\u0444\u0440\u0430\u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0430 \u0432 \u043a\u043e\u043d\u0442\u0435\u0439\u043d\u0435\u0440\u0430\u0445.<\/p>\n<p>\u0420\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442:<\/p>\n<div>\n<div class=\"table\">\n<table>\n<tbody>\n<tr>\n<th>\n<p align=\"left\">\u042d\u043d\u0434\u043f\u043e\u0438\u043d\u0442<\/p>\n<\/th>\n<th>\n<p align=\"left\">\u0418\u0442\u0435\u0440\/\u0441\u0435\u043a<\/p>\n<\/th>\n<th>\n<p align=\"left\">avg<\/p>\n<\/th>\n<th>\n<p align=\"left\">p95<\/p>\n<\/th>\n<th>\n<p align=\"left\">CPU \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f \u043d\u0430 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435<\/p>\n<\/th>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">\/replication<\/p>\n<\/td>\n<td>\n<p align=\"left\">5 625<\/p>\n<\/td>\n<td>\n<p align=\"left\">43.9 ms<\/p>\n<\/td>\n<td>\n<p align=\"left\">65.1 ms<\/p>\n<\/td>\n<td>\n<p align=\"left\">0.382 ms<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">\/direct<\/p>\n<\/td>\n<td>\n<p align=\"left\">5 133<\/p>\n<\/td>\n<td>\n<p align=\"left\">48.0 ms<\/p>\n<\/td>\n<td>\n<p align=\"left\">76.9 ms<\/p>\n<\/td>\n<td>\n<p align=\"left\">0.353 ms<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">\/naive (Kafka)<\/p>\n<\/td>\n<td>\n<p align=\"left\">705<\/p>\n<\/td>\n<td>\n<p align=\"left\">350.5 ms<\/p>\n<\/td>\n<td>\n<p align=\"left\">410.4 ms<\/p>\n<\/td>\n<td>\n<p align=\"left\">1.274 ms<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">\/debezium (100\u043c\u0441)<\/p>\n<\/td>\n<td>\n<p align=\"left\">477<\/p>\n<\/td>\n<td>\n<p align=\"left\">507.8 ms<\/p>\n<\/td>\n<td>\n<p align=\"left\">908.4 ms<\/p>\n<\/td>\n<td>\n<p align=\"left\">1.647 ms<\/p>\n<\/td>\n<\/tr>\n<tr>\n<td>\n<p align=\"left\">\/outbox (100\u043c\u0441)<\/p>\n<\/td>\n<td>\n<p align=\"left\">56.2<\/p>\n<\/td>\n<td>\n<p align=\"left\">4 378.4 ms<\/p>\n<\/td>\n<td>\n<p align=\"left\">4 804.5 ms<\/p>\n<\/td>\n<td>\n<p align=\"left\">3.250 ms<\/p>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n<p><code>\/replication<\/code> \u043e\u0431\u0433\u043e\u043d\u044f\u0435\u0442 <code>\/naive<\/code> \u0432 8 \u0440\u0430\u0437 \u043f\u043e throughput \u0438 \u043f\u043e \u0437\u0430\u0434\u0435\u0440\u0436\u043a\u0435. \u041f\u0440\u0438\u0447\u0451\u043c \u0432 CPU-\u0432\u0440\u0435\u043c\u0435\u043d\u0438 \u043d\u0430 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0440\u0430\u0437\u0440\u044b\u0432 \u0435\u0449\u0451 \u0447\u0435\u0441\u0442\u043d\u0435\u0435: 0.382 \u043c\u0441 \u043f\u0440\u043e\u0442\u0438\u0432 1.274 \u043c\u0441 \u2014 Kafka-\u043f\u0443\u0442\u044c \u0432 3.3 \u0440\u0430\u0437\u0430 \u0434\u043e\u0440\u043e\u0436\u0435 \u043f\u043e \u0444\u0430\u043a\u0442\u0443 \u043f\u043e\u0442\u0440\u0430\u0447\u0435\u043d\u043d\u044b\u0445 \u0442\u0430\u043a\u0442\u043e\u0432, \u043f\u0440\u0438 \u044d\u0442\u043e\u043c \u043c\u0435\u043d\u0435\u0435 \u043d\u0430\u0434\u0435\u0436\u0435\u043d.<\/p>\n<h3>\u041f\u043e\u0447\u0435\u043c\u0443 Debezium \u0438 outbox \u0433\u043e\u0440\u0430\u0437\u0434\u043e \u043c\u0435\u0434\u043b\u0435\u043d\u043d\u0435\u0435<\/h3>\n<ul>\n<li>\n<p><strong>Debezium:<\/strong> <code>poll.interval.ms<\/code> Kafka Connect (\u043f\u043e \u0443\u043c\u043e\u043b\u0447\u0430\u043d\u0438\u044e 500 \u043c\u0441). \u0423\u043c\u0435\u043d\u044c\u0448\u0435\u043d\u0438\u0435 \u0434\u043e 100 \u043c\u0441: 426 \u2192 507 \u0438\u0442\u0435\u0440\/\u0441\u0435\u043a. \u0423\u0437\u043a\u043e\u0435 \u043c\u0435\u0441\u0442\u043e \u2014 \u0442\u0430\u0439\u043c\u0435\u0440 \u043e\u043f\u0440\u043e\u0441\u0430.<\/p>\n<\/li>\n<li>\n<p><strong>ZeroAlloc.Outbox:<\/strong> \u0417\u0430\u0434\u0435\u0440\u0436\u043a\u0438 \u0434\u0430\u0435\u0442 \u043d\u0435 \u0438\u043d\u0442\u0435\u0440\u0432\u0430\u043b \u043e\u043f\u0440\u043e\u0441\u0430, \u0430 \u043f\u043e\u0441\u043b\u0435\u0434\u043e\u0432\u0430\u0442\u0435\u043b\u044c\u043d\u0430\u044f \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0430 \u0432\u043d\u0443\u0442\u0440\u0438 \u0431\u0430\u0442\u0447\u0430 (<code>BatchSize = 50<\/code>). \u0423\u043c\u0435\u043d\u044c\u0448\u0435\u043d\u0438\u0435 \u0438\u043d\u0442\u0435\u0440\u0432\u0430\u043b\u0430 \u0441 1\u0441 \u0434\u043e 100\u043c\u0441: 28 \u2192 56 \u0438\u0442\u0435\u0440\/\u0441\u0435\u043a (\u00d72, \u0430 \u043d\u0435 \u00d710). \u0414\u0430\u043b\u044c\u043d\u0435\u0439\u0448\u0435\u0435 \u0443\u043c\u0435\u043d\u044c\u0448\u0435\u043d\u0438\u0435 \u0431\u0435\u0441\u0441\u043c\u044b\u0441\u043b\u0435\u043d\u043d\u043e \u2014 \u043d\u0443\u0436\u043d\u043e \u0434\u0435\u043b\u0430\u0442\u044c \u0431\u0430\u0442\u0447 \u043d\u0430 \u043a\u043b\u0438\u0435\u043d\u0442\u0435, \u043d\u043e \u0434\u043b\u044f \u044d\u0442\u043e\u0433\u043e \u043d\u0430\u0434\u043e \u043f\u0438\u0441\u0430\u0442\u044c \u0441\u0432\u043e\u0439 Outbox.<\/p>\n<\/li>\n<\/ul>\n<h2>\u0413\u043b\u0430\u0432\u0430 8. \u00ab\u0410 \u0447\u0442\u043e \u0435\u0441\u043b\u0438 \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0430 \u0432\u044b\u0440\u0430\u0441\u0442\u0435\u0442?\u00bb<\/h2>\n<p>\u041f\u0440\u0430\u043a\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u043b\u044e\u0431\u043e\u0439 \u0440\u0430\u0437\u0433\u043e\u0432\u043e\u0440 \u043e \u043d\u0443\u0436\u043d\u043e\u0441\u0442\u0438 \u041a\u0430\u0444\u043a\u0438 \u0441\u0432\u043e\u0434\u0438\u0442\u0441\u044f \u043a \u044d\u0442\u043e\u043c\u0443 \u0430\u0440\u0433\u0443\u043c\u0435\u043d\u0442\u0443.<\/p>\n<p>\u041d\u043e \u043d\u0430\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u0440\u0435\u0430\u043b\u044c\u043d\u043e \u043c\u043e\u0436\u043d\u043e \u043f\u043e\u0438\u043c\u0435\u0442\u044c \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u044b:<\/p>\n<ul>\n<li>\n<p>\u0412\u0440\u044f\u0434 \u043b\u0438 \u0443 \u0432\u0430\u0441 \u0431\u0443\u0434\u0435\u0442 \u0442\u0430\u043a \u043c\u043d\u043e\u0433\u043e \u0434\u0430\u043d\u043d\u044b\u0445 <a href=\"https:\/\/topicpartition.io\/definitions\/small-data\" rel=\"noopener nofollow\">https:\/\/topicpartition.io\/definitions\/small-data<\/a>, \u0432\u0430\u0448 \u0431\u0438\u0437\u043d\u0435\u0441 \u0438 \u043a\u043e\u0434\u043e\u0432\u0430\u044f \u0431\u0430\u0437\u0430 \u043d\u0435 \u0440\u0430\u0441\u0442\u0443\u0442 \u0442\u0430\u043a \u0431\u044b\u0441\u0442\u0440\u043e.<\/p>\n<\/li>\n<li>\n<p>\u041f\u043e \u0434\u0430\u043d\u043d\u044b\u043c aiven.io <a href=\"https:\/\/aiven.io\/blog\/apache-kafkas-80-percent-problem\" rel=\"noopener nofollow\">80% Kafka \u043a\u043b\u0430\u0441\u0442\u0435\u0440\u043e\u0432 \u043d\u0435 \u043f\u0440\u0435\u0432\u044b\u0448\u0430\u044e\u0442 1 \u041c\u0411\/\u0441<\/a><\/p>\n<\/li>\n<li>\n<p><a href=\"https:\/\/cdn.prod.website-files.com\/6659da8aecd70e0898c0d7ed\/672fb52dc29ab4cdf8a59525_The-State-of-Streaming-Data_Report-by-Redpanda.pdf\" rel=\"noopener nofollow\">\u041e\u0442\u0447\u0435\u0442 RedPanda<\/a> \u0437\u0430 2023-2024 \u0433\u043e\u0434 \u043f\u043e\u043a\u0430\u0437\u044b\u0432\u0430\u0435\u0442, \u0447\u0442\u043e \u0443 56% \u043a\u043e\u043c\u043f\u0430\u043d\u0438\u0439 \u0442\u0440\u0430\u0444\u0438\u043a \u0434\u0430\u043d\u043d\u044b\u0445  \u22641 \u041c\u0411\/\u0441<\/p>\n<\/li>\n<li>\n<p><a href=\"https:\/\/topicpartition.io\/blog\/postgres-pubsub-queue-benchmarks\" rel=\"noopener nofollow\">Postgres \u0434\u043e\u0441\u0442\u0430\u0442\u043e\u0447\u043d\u043e \u0431\u044b\u0441\u0442\u0440<\/a> \u0447\u0442\u043e\u0431\u044b \u043d\u0430 \u0441\u043e\u0432\u0440\u0435\u043c\u0435\u043d\u043d\u044b\u0445 \u0434\u0438\u0441\u043a\u0430\u0445 \u0434\u0435\u0440\u0436\u0430\u0442\u044c \u043e\u0433\u0440\u043e\u043c\u043d\u044b\u0435 \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438<\/p>\n<\/li>\n<\/ul>\n<p>\u041d\u0430\u0448 \u0441\u043e\u0431\u0441\u0442\u0432\u0435\u043d\u043d\u044b\u0439 \u0437\u0430\u043c\u0435\u0440: \u0434\u043e 5 600 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u0432 \u0441\u0435\u043a\u0443\u043d\u0434\u0443 \u0438 1,3 \u041c\u0411\/\u0441 \u0447\u0435\u0440\u0435\u0437 \u043f\u0440\u044f\u043c\u0443\u044e WAL-\u0440\u0435\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u044e \u2014 \u043d\u0430 \u043e\u0434\u043d\u043e\u043c CPU, \u0431\u0435\u0437 \u0435\u0434\u0438\u043d\u043e\u0439 \u043e\u043f\u0442\u0438\u043c\u0438\u0437\u0430\u0446\u0438\u0438.<\/p>\n<p>\u041f\u043e\u0434\u0430\u0432\u043b\u044f\u044e\u0449\u0435\u0435 \u0431\u043e\u043b\u044c\u0448\u0438\u043d\u0441\u0442\u0432\u043e \u0441\u0438\u0441\u0442\u0435\u043c, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u0441\u0435\u0433\u043e\u0434\u043d\u044f \u043f\u043b\u0430\u0442\u044f\u0442 \u0437\u0430 Kafka, \u0444\u0438\u0437\u0438\u0447\u0435\u0441\u043a\u0438 \u043d\u0435 \u043f\u0440\u0438\u0431\u043b\u0438\u0436\u0430\u044e\u0442\u0441\u044f \u043a \u0433\u0440\u0430\u043d\u0438\u0446\u0430\u043c, \u0437\u0430 \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043b\u043e\u0433\u0438\u0447\u0435\u0441\u043a\u0430\u044f \u0440\u0435\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u044f \u043d\u0435 \u0432\u044b\u0445\u043e\u0434\u0438\u0442.<\/p>\n<h3>\u041a\u043e\u0433\u0434\u0430 Kafka \u0434\u0435\u0439\u0441\u0442\u0432\u0438\u0442\u0435\u043b\u044c\u043d\u043e \u043d\u0443\u0436\u043d\u0430<\/h3>\n<ul>\n<li>\n<p>\u041c\u043d\u043e\u0433\u043e \u0440\u0430\u0437\u043d\u043e\u0440\u043e\u0434\u043d\u044b\u0445 downstream-\u043f\u043e\u0442\u0440\u0435\u0431\u0438\u0442\u0435\u043b\u0435\u0439 \u043d\u0435 \u043f\u043e\u0434 \u0432\u0430\u0448\u0438\u043c \u043a\u043e\u043d\u0442\u0440\u043e\u043b\u0435\u043c<\/p>\n<\/li>\n<li>\n<p>\u0414\u0435\u0441\u044f\u0442\u043a\u0438 \u0442\u044b\u0441\u044f\u0447 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439\/\u0441\u0435\u043a \u0438 \u0440\u0430\u0441\u0442\u0451\u0442<\/p>\n<\/li>\n<li>\n<p>\u0411\u0438\u0437\u043d\u0435\u0441\u0443 \u043d\u0443\u0436\u043d\u0430 \u0434\u043e\u043b\u0433\u0430\u044f \u0438\u0441\u0442\u043e\u0440\u0438\u044f \u0441 \u043f\u0440\u043e\u0438\u0437\u0432\u043e\u043b\u044c\u043d\u043e\u0439 \u043f\u0435\u0440\u0435\u043c\u043e\u0442\u043a\u043e\u0439 \\ \u043f\u0440\u0435\u0440\u0435\u043f\u0440\u043e\u0438\u0433\u0440\u044b\u0432\u0430\u043d\u0438\u0435\u043c \u0438\u0441\u0442\u043e\u0440\u0438\u0438, \u0438 \u0432\u044b \u043c\u043e\u0436\u0435\u0442\u0435 \u044d\u0442\u043e \u0441\u0434\u0435\u043b\u0430\u0442\u044c \u0437\u0430 \u0440\u0430\u0437\u0443\u043c\u043d\u043e\u0435 \u0432\u0440\u0435\u043c\u044f<\/p>\n<\/li>\n<li>\n<p>\u041c\u043d\u043e\u0433\u043e \u043c\u0435\u0434\u043b\u0435\u043d\u043d\u044b\u0445 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u043e\u0432 \u0438  \u0438\u0445 \u0447\u0438\u0441\u043b\u043e \u043c\u0435\u043d\u044f\u0435\u0442\u0441\u044f (\u043d\u0435 \u0441\u043e\u0432\u043c\u0435\u0441\u0442\u0438\u043c\u043e \u0441 \u043f\u0440\u0435\u0434\u044b\u0434\u0443\u0449\u0438\u043c)<\/p>\n<\/li>\n<\/ul>\n<h3>\u041a\u043e\u0433\u0434\u0430 \u043b\u043e\u0433\u0438\u0447\u0435\u0441\u043a\u043e\u0439 \u0440\u0435\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u0438 \u0434\u043e\u0441\u0442\u0430\u0442\u043e\u0447\u043d\u043e<\/h3>\n<ul>\n<li>\n<p>\u0412\u044b \u0432\u043b\u0430\u0434\u0435\u0435\u0442\u0435 \u0438 \u043f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u043e\u043c, \u0438 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u043e\u043c<\/p>\n<\/li>\n<li>\n<p>\u041d\u0430\u0433\u0440\u0443\u0437\u043a\u0430 \u0434\u043e \u0434\u0435\u0441\u044f\u0442\u043a\u043e\u0432 \u0442\u044b\u0441\u044f\u0447 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439\/\u0441\u0435\u043a<\/p>\n<\/li>\n<li>\n<p>\u0425\u043e\u0442\u0438\u0442\u0435 \u0443\u0434\u0435\u0448\u0435\u0432\u0438\u0442\u044c \u0438\u043d\u0444\u0440\u0430\u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0443<\/p>\n<\/li>\n<li>\n<p>\u041a\u0440\u0438\u0442\u0438\u0447\u043d\u0430 \u043a\u043e\u043d\u0441\u0438\u0441\u0442\u0435\u043d\u0442\u043d\u043e\u0441\u0442\u044c \u0438 \u0437\u0430\u0434\u0435\u0440\u0436\u043a\u0438<\/p>\n<\/li>\n<\/ul>\n<h2>\u0424\u0438\u043d\u0430\u043b: \u043c\u044b \u0432\u0435\u0440\u043d\u0443\u043b\u0438\u0441\u044c \u0442\u0443\u0434\u0430, \u043e\u0442\u043a\u0443\u0434\u0430 \u043d\u0430\u0447\u0430\u043b\u0438<\/h2>\n<p>\u041c\u044b \u0441\u0434\u0435\u043b\u0430\u043b\u0438 \u043f\u043e\u043b\u043d\u044b\u0439 \u043a\u0440\u0443\u0433. \u041f\u0440\u044f\u043c\u043e\u0439 \u0432\u044b\u0437\u043e\u0432 \u2192 Kafka, \u0447\u0442\u043e\u0431\u044b \u0440\u0430\u0437\u043d\u0435\u0441\u0442\u0438 \u0441\u0435\u0440\u0432\u0438\u0441\u044b \u2192 outbox (\u0447\u0435\u0440\u0435\u0437 <code>ZeroAlloc.Outbox<\/code>), \u0447\u0442\u043e\u0431\u044b Kafka \u043d\u0435 \u0442\u0435\u0440\u044f\u043b\u0430 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u2192 Debezium, \u0447\u0442\u043e\u0431\u044b outbox \u043d\u0435 \u0433\u0440\u0443\u0437\u0438\u043b \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0435 \u2192 \u043f\u0440\u044f\u043c\u043e\u0435 \u0447\u0442\u0435\u043d\u0438\u0435 WAL, \u043a\u043e\u0434 \u044d\u043d\u0434\u043f\u043e\u0438\u043d\u0442\u0430 <code>\/replication<\/code> \u0432\u044b\u0433\u043b\u044f\u0434\u0438\u0442 \u043a\u0430\u043a \u043a\u043e\u0434 \u043f\u0440\u044f\u043c\u043e\u0433\u043e \u0432\u044b\u0437\u043e\u0432\u0430.<\/p>\n<p>\u041c\u043e\u0440\u0430\u043b\u044c: <em>\u0418\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0439\u0442\u0435 Postgres, \u043f\u043e\u043a\u0430 \u043d\u0435 \u0441\u0442\u043e\u043b\u043a\u043d\u0443\u043b\u0438\u0441\u044c \u0441 \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u0430\u043c\u0438 \u043c\u0430\u0441\u0448\u0442\u0430\u0431\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f<\/em>. \u041a\u043e\u0433\u0434\u0430 \u0441\u0442\u043e\u043b\u043a\u043d\u0451\u0442\u0435\u0441\u044c \u2014 \u0443 \u0432\u0430\u0441 \u0431\u0443\u0434\u0435\u0442 \u043a\u043e\u043d\u043a\u0440\u0435\u0442\u043d\u0430\u044f \u0438\u0437\u043c\u0435\u0440\u0435\u043d\u043d\u0430\u044f \u043c\u0435\u0442\u0440\u0438\u043a\u0430, \u0447\u0442\u043e\u0431\u044b \u043e\u0431\u043e\u0441\u043d\u043e\u0432\u0430\u0442\u044c \u0434\u043e\u0431\u0430\u0432\u043b\u0435\u043d\u0438\u0435 Kafka \u0438\u043b\u0438 \u0434\u0440\u0443\u0433\u043e\u0433\u043e \u043a\u043e\u043c\u043f\u043e\u043d\u0435\u043d\u0442\u0430. \u0410 \u043d\u0435 \u0430\u0431\u0441\u0442\u0440\u0430\u043a\u0442\u043d\u043e\u0435 <em>\u00ab\u0442\u0430\u043a \u043f\u0440\u0438\u043d\u044f\u0442\u043e \u0432 \u043c\u0438\u043a\u0440\u043e\u0441\u0435\u0440\u0432\u0438\u0441\u0430\u0445\u00bb<\/em>.<\/p>\n<\/div>\n<p>\u0441\u0441\u044b\u043b\u043a\u0430 \u043d\u0430 \u043e\u0440\u0438\u0433\u0438\u043d\u0430\u043b \u0441\u0442\u0430\u0442\u044c\u0438 <a href=\"https:\/\/habr.com\/ru\/articles\/1082062\/\">https:\/\/habr.com\/ru\/articles\/1082062\/<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"<p>\u041a\u0430\u0440\u0442\u0438\u043d\u043a\u0430 \u0434\u043b\u044f \u043f\u0440\u0438\u0432\u043b\u0435\u0447\u0435\u043d\u0438\u044f \u0432\u043d\u0438\u043c\u0430\u043d\u0438\u044f\u042d\u0442\u043e \u0438\u0441\u0442\u043e\u0440\u0438\u044f \u043f\u0440\u043e \u0430\u0440\u0445\u0438\u0442\u0435\u043a\u0442\u0443\u0440\u0443 \u043e\u0434\u043d\u043e\u0433\u043e \u0441\u0435\u0440\u0432\u0438\u0441\u0430. \u0420\u0430\u0441\u0441\u043a\u0430\u0437\u0430\u043d\u043d\u0430\u044f \u0434\u043e \u043a\u043e\u043d\u0446\u0430, \u0430 \u043d\u0435 \u0442\u043e\u043b\u044c\u043a\u043e \u0434\u043e \u0442\u043e\u0433\u043e \u043c\u0435\u0441\u0442\u0430, \u0433\u0434\u0435 \u043e\u0431\u044b\u0447\u043d\u043e \u043e\u0441\u0442\u0430\u043d\u0430\u0432\u043b\u0438\u0432\u0430\u044e\u0442\u0441\u044f \u0441\u0442\u0430\u0442\u044c\u0438 \u043f\u0440\u043e \u0430\u0440\u0445\u0438\u0442\u0435\u043a\u0442\u0443\u0440\u0443. \u041d\u0430\u043c\u0435\u0440\u0435\u043d\u043d\u043e \u0443\u043f\u0440\u043e\u0449\u0435\u043d\u0430 \u0431\u0438\u0437\u043d\u0435\u0441-\u043b\u043e\u0433\u0438\u043a\u0430, \u0447\u0442\u043e\u0431\u044b \u043d\u0435 \u0440\u0430\u0437\u043c\u044b\u0432\u0430\u0442\u044c \u043e\u0441\u043d\u043e\u0432\u043d\u043e\u0439 \u0441\u043c\u044b\u0441\u043b.\u0413\u043b\u0430\u0432\u0430 1. \u0412 \u043d\u0430\u0447\u0430\u043b\u0435 \u0431\u044b\u043b\u043e \u043f\u0440\u043e\u0441\u0442\u043e\u0421\u0435\u0440\u0432\u0438\u0441 \u043f\u0440\u0438\u043d\u0438\u043c\u0430\u043b \u0437\u0430\u043f\u0440\u043e\u0441, \u043f\u0438\u0441\u0430\u043b \u0441\u0442\u0440\u043e\u043a\u0443 \u0432 \u0431\u0430\u0437\u0443, \u043e\u0442\u0432\u0435\u0447\u0430\u043b 201. \u042d\u0442\u043e \u0432\u0435\u0441\u044c \u043a\u043e\u0434:app.MapPost(&#171;\/direct&#187;, async (Message dto, AppDbContext db, CancellationToken ct) =&gt;{    Message msg = new() { Content = dto.Content, CreatedAt = DateTime.UtcNow };    db.Messages.Add(msg);    await db.SaveChangesAsync(ct);    return Results.Created($&#187;\/messages\/{msg.Id}&#187;, msg);});\u041d\u0438\u043a\u0442\u043e \u043d\u0435 \u043f\u0438\u0448\u0435\u0442 \u0441\u0442\u0430\u0442\u0435\u0439 \u043f\u0440\u043e \u044d\u0442\u043e\u0442 \u043a\u043e\u0434, \u043f\u043e\u0442\u043e\u043c\u0443 \u0447\u0442\u043e \u0432 \u043d\u0451\u043c \u043d\u0435\u0447\u0435\u0433\u043e \u043e\u0431\u0441\u0443\u0436\u0434\u0430\u0442\u044c. \u041d\u043e \u0438\u043c\u0435\u043d\u043d\u043e \u043e\u0431 \u043d\u0435\u0433\u043e \u0440\u0430\u0437\u0431\u0438\u0432\u0430\u044e\u0442\u0441\u044f \u0432\u0441\u0435 \u043f\u043e\u0441\u043b\u0435\u0434\u0443\u044e\u0449\u0438\u0435 \u0440\u0435\u0448\u0435\u043d\u0438\u044f \u2014 \u0434\u0435\u0440\u0436\u0438\u0442\u0435 \u0435\u0433\u043e \u0432 \u0433\u043e\u043b\u043e\u0432\u0435, \u043e\u043d \u0435\u0449\u0451 \u043f\u0440\u0438\u0433\u043e\u0434\u0438\u0442\u0441\u044f \u0432 \u0444\u0438\u043d\u0430\u043b\u0435.\u0413\u043b\u0430\u0432\u0430 2. \u00ab\u041d\u0430\u043c \u043d\u0443\u0436\u043d\u0430 \u043e\u0447\u0435\u0440\u0435\u0434\u044c\u00bb \u2014 \u0438 \u0432\u043e\u0442 \u043f\u043e\u0447\u0435\u043c\u0443 \u044d\u0442\u043e \u043d\u0435 \u0433\u043b\u0443\u043f\u043e\u0441\u0442\u044c\u0420\u0430\u043d\u043e \u0438\u043b\u0438 \u043f\u043e\u0437\u0434\u043d\u043e \u043e\u0434\u0438\u043d \u0441\u0435\u0440\u0432\u0438\u0441 \u043f\u0435\u0440\u0435\u0441\u0442\u0430\u0451\u0442 \u0431\u044b\u0442\u044c \u043e\u0434\u043d\u0438\u043c \u0441\u0435\u0440\u0432\u0438\u0441\u043e\u043c. \u041f\u043e\u044f\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u0432\u0442\u043e\u0440\u043e\u0439, \u043a\u043e\u0442\u043e\u0440\u043e\u043c\u0443 \u0432\u0430\u0436\u043d\u043e \u0443\u0437\u043d\u0430\u0442\u044c \u043e \u0442\u043e\u043c \u0436\u0435 \u0441\u043e\u0431\u044b\u0442\u0438\u0438 \u2014 \u043e\u0431\u0441\u0447\u0438\u0442\u0430\u0442\u044c \u0430\u043d\u0430\u043b\u0438\u0442\u0438\u043a\u0443, \u043e\u0431\u043d\u043e\u0432\u0438\u0442\u044c \u043f\u043e\u0438\u0441\u043a\u043e\u0432\u044b\u0439 \u0438\u043d\u0434\u0435\u043a\u0441, \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u044c \u043f\u0438\u0441\u044c\u043c\u043e. \u0412\u043e\u0437\u043d\u0438\u043a\u0430\u0435\u0442 \u0441\u043e\u0431\u043b\u0430\u0437\u043d \u043f\u0440\u043e\u0441\u0442\u043e \u0434\u0451\u0440\u043d\u0443\u0442\u044c \u0435\u0433\u043e \u043f\u043e HTTP, \u0438 \u044d\u0442\u043e \u043f\u0435\u0440\u0432\u0430\u044f \u043e\u0448\u0438\u0431\u043a\u0430, \u043a\u043e\u0442\u043e\u0440\u0443\u044e \u0432\u0441\u0435 \u0441\u043e\u0432\u0435\u0440\u0448\u0430\u044e\u0442 \u0438 \u0432\u0441\u0435 \u0436\u0435 \u0438\u0441\u043f\u0440\u0430\u0432\u043b\u044f\u044e\u0442: \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439 \u0432\u044b\u0437\u043e\u0432 \u0434\u0435\u043b\u0430\u0435\u0442 \u0432\u0430\u0441 \u043d\u0430\u0441\u0442\u043e\u043b\u044c\u043a\u043e \u0436\u0435 \u043d\u0430\u0434\u0451\u0436\u043d\u044b\u043c, \u043d\u0430\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u043d\u0430\u0434\u0451\u0436\u0435\u043d \u0441\u0430\u043c\u044b\u0439 \u0445\u0440\u0443\u043f\u043a\u0438\u0439 \u0438\u0437 \u0432\u0430\u0448\u0438\u0445 \u0441\u043e\u0441\u0435\u0434\u0435\u0439.\u0417\u043d\u0430\u0447\u0438\u0442 \u043d\u0443\u0436\u043d\u043e \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e, \u0447\u0435\u0440\u0435\u0437 \u0431\u0440\u043e\u043a\u0435\u0440. \u0418 \u043f\u043e\u0447\u0442\u0438 \u0432\u0441\u0435\u0433\u0434\u0430 \u044d\u0442\u0438\u043c \u0431\u0440\u043e\u043a\u0435\u0440\u043e\u043c \u043e\u043a\u0430\u0437\u044b\u0432\u0430\u0435\u0442\u0441\u044f Kafka. \u042d\u0442\u043e \u043d\u0435 \u043a\u0430\u0440\u0433\u043e-\u043a\u0443\u043b\u044c\u0442, \u0430 \u0440\u0430\u0446\u0438\u043e\u043d\u0430\u043b\u044c\u043d\u044b\u0439 \u0432\u044b\u0431\u043e\u0440:80%+ \u043a\u043e\u043c\u043f\u0430\u043d\u0438\u0439 \u0438\u0437 Fortune 100 \u0435\u0451 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044e\u0442, \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u0438\u0435 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0438 \u0435\u0441\u0442\u044c \u0434\u043b\u044f \u0432\u0441\u0435\u0445 \u044f\u0437\u044b\u043a\u043e\u0432 (kafka.apache.org\/powered-by)\u041f\u0440\u043e\u0432\u0435\u0440\u0435\u043d\u0430 \u0432 \u0431\u043e\u044e: \u0432\u044b\u0440\u043e\u0441\u043b\u0430 \u0438\u0437 LinkedIn, \u0433\u0434\u0435 \u0433\u043e\u043d\u044f\u043b\u0438 \u043c\u0438\u043b\u043b\u0438\u0430\u0440\u0434\u044b \u0441\u043e\u0431\u044b\u0442\u0438\u0439 \u0432 \u0434\u0435\u043d\u044c. Netflix, Uber, Goldman Sachs \u2014 \u0432\u0441\u0435 \u043d\u0430 \u043d\u0435\u0439 (\u043f\u043e\u0434\u0440\u043e\u0431\u043d\u0435\u0435 \u043e \u0442\u043e\u043c, \u043a\u0430\u043a Kafka \u0443\u0441\u0442\u0440\u043e\u0435\u043d\u0430 \u0432\u043d\u0443\u0442\u0440\u0438)\u041c\u0430\u0441\u0448\u0442\u0430\u0431\u0438\u0440\u0443\u0435\u0442\u0441\u044f \u043b\u0438\u043d\u0435\u0439\u043d\u043e: \u043f\u0430\u0440\u0442\u0438\u0446\u0438\u0438 + consumer groups, \u0434\u043e\u0431\u0430\u0432\u043b\u044f\u0439 \u0431\u0440\u043e\u043a\u0435\u0440\u043e\u0432 \u0431\u0435\u0437 \u0438\u0437\u043c\u0435\u043d\u0435\u043d\u0438\u044f \u043a\u043e\u0434\u0430\u0413\u043e\u0442\u043e\u0432\u0430\u044f \u043c\u043e\u0434\u0435\u043b\u044c \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438: pull, \u043f\u0435\u0440\u0441\u0438\u0441\u0442\u0435\u043d\u0442\u043d\u044b\u0439 \u043b\u043e\u0433, \u0440\u0435\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u044f, \u043d\u0430\u0441\u0442\u0440\u0430\u0438\u0432\u0430\u0435\u043c\u043e\u0435 \u0445\u0440\u0430\u043d\u0435\u043d\u0438\u0435\u0412 \u043a\u043e\u043d\u0446\u0435 \u043a\u043e\u043d\u0446\u043e\u0432 \u044d\u0442\u043e \u043c\u043e\u0434\u043d\u043e.\u0412 \u043a\u043e\u0434\u0435 \u044d\u0442\u043e \u0432\u044b\u0433\u043b\u044f\u0434\u0438\u0442 \u0442\u0430\u043a:db.Messages.Add(msg);await db.SaveChangesAsync(ct);                    \/\/ (1) \u0437\u0430\u043f\u0438\u0441\u0430\u043b\u0438 \u0432 \u0431\u0430\u0437\u0443await producer.ProduceAsync(KafkaConsumer.Topic, new(){    Timestamp = new(msg.CreatedAt),    Key = msg.Id,    Value = msg}, ct);                                            \/\/ (2) \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u043b\u0438 \u0432 Kafka\u0421\u043f\u0440\u043e\u0441\u0438\u0442\u0435 \u0441\u0435\u0431\u044f: \u0447\u0442\u043e \u0441\u043b\u0443\u0447\u0438\u0442\u0441\u044f, \u0435\u0441\u043b\u0438 \u043f\u0440\u043e\u0446\u0435\u0441\u0441 \u0443\u043f\u0430\u0434\u0451\u0442 \u043c\u0435\u0436\u0434\u0443 \u0441\u0442\u0440\u043e\u043a\u043e\u0439 (1) \u0438 \u0441\u0442\u0440\u043e\u043a\u043e\u0439 (2)? \u0412 \u0431\u0430\u0437\u0435 \u2014 \u0437\u0430\u043f\u0438\u0441\u044c \u0435\u0441\u0442\u044c. \u0412 Kafka \u2014 \u043d\u0438\u0447\u0435\u0433\u043e. Downstream-\u0441\u0435\u0440\u0432\u0438\u0441 \u043d\u0438\u043a\u043e\u0433\u0434\u0430 \u043d\u0435 \u0443\u0437\u043d\u0430\u0435\u0442, \u0447\u0442\u043e \u0441\u043e\u0431\u044b\u0442\u0438\u0435 \u043f\u0440\u043e\u0438\u0437\u043e\u0448\u043b\u043e.\u0441\u0445\u0435\u043c\u0430 1\u0418 \u044d\u0442\u043e \u043d\u0435 \u044d\u043a\u0437\u043e\u0442\u0438\u043a\u0430 \u043d\u0430 0.001% \u0438\u043d\u0446\u0438\u0434\u0435\u043d\u0442\u043e\u0432. CancellationToken \u043f\u043e \u0437\u0430\u043a\u0440\u044b\u0442\u0438\u044e \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f \u043a\u043b\u0438\u0435\u043d\u0442\u0430 \u2014 \u0442\u0430\u0439\u043c\u0430\u0443\u0442, \u0437\u0430\u043a\u0440\u044b\u0442\u0438\u0435 \u0438\u043b\u0438 \u043e\u0431\u043d\u043e\u0432\u043b\u0435\u043d\u0438\u0435 \u0441\u0442\u0440\u0430\u043d\u0438\u0446\u044b, \u043a\u0440\u043e\u043c\u0435 \u0442\u043e\u0433\u043e \u0441\u043b\u0443\u0447\u0430\u0435\u0442\u0441\u044f \u0440\u0435\u0441\u0442\u0430\u0440\u0442 \u043f\u043e\u0434\u0430, \u0434\u0435\u043f\u043b\u043e\u0439, OOM-killer, \u0434\u0430 \u043f\u0440\u043e\u0441\u0442\u043e \u0438\u0441\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0435 \u0432\u043d\u0443\u0442\u0440\u0438 ProduceAsync \u2014 \u043b\u044e\u0431\u043e\u0435 \u0438\u0437 \u044d\u0442\u043e\u0433\u043e \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u043e \u0441\u043e\u0437\u0434\u0430\u0451\u0442 \u0434\u044b\u0440\u0443.\u042d\u0442\u043e dual write problem: \u0434\u0432\u0430 \u043d\u0435\u0437\u0430\u0432\u0438\u0441\u0438\u043c\u044b\u0445 \u0440\u0435\u0441\u0443\u0440\u0441\u0430 \u043e\u0431\u043d\u043e\u0432\u043b\u044f\u044e\u0442\u0441\u044f \u043d\u0435 \u0430\u0442\u043e\u043c\u0430\u0440\u043d\u043e. \u041d\u0435\u043b\u044c\u0437\u044f \u043e\u0431\u0435\u0440\u043d\u0443\u0442\u044c INSERT \u0432 Postgres \u0438 ProduceAsync \u0432 Kafka \u0432 \u043e\u0434\u043d\u0443 \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u044e. \u041e\u043d\u0438 \u043f\u0440\u043e\u0441\u0442\u043e \u043d\u0435 \u0437\u043d\u0430\u044e\u0442 \u0434\u0440\u0443\u0433 \u043e \u0434\u0440\u0443\u0433\u0435.\u0414\u0435\u043b\u0430\u0442\u044c \u0437\u0430\u043f\u0438\u0441\u044c \u0438 \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0443 \u0432 \u043e\u0431\u0440\u0430\u0442\u043d\u043e\u043c \u043f\u043e\u0440\u044f\u0434\u043a\u0435 &#8212; \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u0442\u0441\u044f \u0435\u0449\u0435 \u0445\u0443\u0436\u0435.\u00ab\u041f\u0440\u043e\u0441\u0442\u043e \u0440\u0435\u0442\u0440\u0430\u0438\u0442\u044c\u00bb \u043d\u0435 \u043f\u043e\u043c\u043e\u0433\u0430\u0435\u0442:\u0421\u0435\u0440\u0432\u0438\u0441 \u043f\u0430\u0434\u0430\u0435\u0442 \u0434\u043e \u0440\u0435\u0442\u0440\u0430\u044f \u2192 \u0441\u043e\u0431\u044b\u0442\u0438\u0435 \u043f\u043e\u0442\u0435\u0440\u044f\u043d\u043e\u0420\u0435\u0442\u0440\u0430\u0439 \u043f\u0440\u043e\u0445\u043e\u0434\u0438\u0442, \u043d\u043e \u0438 \u043e\u0440\u0438\u0433\u0438\u043d\u0430\u043b \u043f\u0440\u043e\u0448\u0451\u043b \u2192 \u0434\u0443\u0431\u043b\u0438\u043a\u0430\u0442\u0420\u0435\u0442\u0440\u0430\u0438\u043c \u0438 \u0431\u0430\u0437\u0443 \u0442\u043e\u0436\u0435 \u2192 \u0434\u0443\u0431\u043b\u0438\u043a\u0430\u0442 \u0437\u0430\u043a\u0430\u0437\u0430\u0413\u043b\u0430\u0432\u0430 3. \u0413\u0430\u0440\u0430\u043d\u0442\u0438\u044f \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0438\u041c\u043e\u0436\u0435\u0442, \u0440\u0430\u0441\u043f\u0440\u0435\u0434\u0435\u043b\u0451\u043d\u043d\u0430\u044f \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u044f? 2PC? \u041a \u0441\u043e\u0436\u0430\u043b\u0435\u043d\u0438\u044e \u043d\u0435\u0442:Kafka \u043d\u0435 \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u0438\u0432\u0430\u0435\u0442 XA. RabbitMQ \u043d\u0435 \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u0438\u0432\u0430\u0435\u0442. SQS \u043d\u0435 \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u0438\u0432\u0430\u0435\u0442.2PC \u0431\u043b\u043e\u043a\u0438\u0440\u0443\u044e\u0449\u0438\u0439: \u043a\u043e\u043e\u0440\u0434\u0438\u043d\u0430\u0442\u043e\u0440 \u043f\u0430\u0434\u0430\u0435\u0442 \u2192 \u0443\u0447\u0430\u0441\u0442\u043d\u0438\u043a\u0438 \u0432\u0438\u0441\u044f\u0442 \u0441 \u043b\u043e\u043a\u0430\u043c\u0438 \u0431\u0435\u0441\u043a\u043e\u043d\u0435\u0447\u043d\u043e30\u201340% \u043f\u043e\u0442\u0435\u0440\u0438 \u043f\u0440\u043e\u043f\u0443\u0441\u043a\u043d\u043e\u0439 \u0441\u043f\u043e\u0441\u043e\u0431\u043d\u043e\u0441\u0442\u0438 \u043f\u043e \u0441\u0440\u0430\u0432\u043d\u0435\u043d\u0438\u044e \u0441 \u043b\u043e\u043a\u0430\u043b\u044c\u043d\u044b\u043c\u0438 \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u044f\u043c\u0438\u0422\u0440\u0435\u0431\u0443\u0435\u0442, \u0447\u0442\u043e\u0431\u044b \u0432\u0441\u0435 \u0443\u0447\u0430\u0441\u0442\u043d\u0438\u043a\u0438 \u0431\u044b\u043b\u0438 \u0434\u043e\u0441\u0442\u0443\u043f\u043d\u044b \u043e\u0434\u043d\u043e\u0432\u0440\u0435\u043c\u0435\u043d\u043d\u043e\u0412\u043e\u0442 \u043a \u0447\u0435\u043c\u0443 \u043c\u044b \u043d\u0430 \u0441\u0430\u043c\u043e\u043c \u0434\u0435\u043b\u0435 \u043f\u0440\u0438\u0448\u043b\u0438: \u0435\u0441\u043b\u0438 \u0432\u044b \u043f\u0438\u0448\u0435\u0442\u0435 \u0432 Kafka \u043d\u0430\u043f\u0440\u044f\u043c\u0443\u044e \u0438\u0437 \u0431\u0438\u0437\u043d\u0435\u0441-\u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u0438 \u2014 \u0432\u044b \u0443\u0436\u0435 \u043d\u0430\u0440\u0443\u0448\u0430\u0435\u0442\u0435 \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u0438. \u0421\u043f\u043e\u0440\u0438\u0442\u044c \u0441 \u044d\u0442\u0438\u043c \u0431\u0435\u0441\u0441\u043c\u044b\u0441\u043b\u0435\u043d\u043d\u043e \u2014 \u043c\u043e\u0436\u043d\u043e \u0442\u043e\u043b\u044c\u043a\u043e \u043b\u0438\u0431\u043e \u043f\u0440\u0438\u043d\u044f\u0442\u044c outbox, \u043b\u0438\u0431\u043e \u0436\u0438\u0442\u044c \u0441 \u043f\u043e\u0442\u0435\u0440\u044f\u043d\u043d\u044b\u043c\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f\u043c\u0438.\u041d\u0430 \u043f\u043e\u043c\u043e\u0449\u044c \u043f\u0440\u0438\u0445\u043e\u0434\u0438\u0442 \u043f\u0430\u0442\u0442\u0435\u0440\u043d Transactional Outbox.\u0415\u0433\u043e \u043d\u0430\u0437\u044b\u0432\u0430\u044e\u0442 \u00ab\u043a\u0430\u043d\u043e\u043d\u0438\u0447\u0435\u0441\u043a\u0438\u043c \u0440\u0435\u0448\u0435\u043d\u0438\u0435\u043c\u00bb \u0434\u043b\u044f \u043d\u0430\u0434\u0451\u0436\u043d\u043e\u0439 \u043f\u0443\u0431\u043b\u0438\u043a\u0430\u0446\u0438\u0438 \u0441\u043e\u0431\u044b\u0442\u0438\u0439 \u2014 \u0444\u043e\u0440\u043c\u0443\u043b\u0438\u0440\u043e\u0432\u043a\u0430 \u0438\u0437 \u0440\u0430\u0437\u0431\u043e\u0440\u0430 \u0443 Chris Richardson, microservices.io.AWS Prescriptive Guidance \u0440\u0435\u043a\u043e\u043c\u0435\u043d\u0434\u0443\u0435\u0442 \u0438\u043c\u0435\u043d\u043d\u043e \u0435\u0433\u043e.Confluent \u0432\u043a\u043b\u044e\u0447\u0430\u0435\u0442 outbox \u043a\u0430\u043a \u043e\u0431\u044f\u0437\u0430\u0442\u0435\u043b\u044c\u043d\u044b\u0439 \u0448\u0430\u0433 \u0432 \u0441\u043e\u0431\u0441\u0442\u0432\u0435\u043d\u043d\u044b\u0439 \u043a\u0443\u0440\u0441 \u043f\u043e \u043c\u0438\u043a\u0440\u043e\u0441\u0435\u0440\u0432\u0438\u0441\u0430\u043c.\u0418\u0434\u0435\u044f \u043f\u0440\u043e\u0441\u0442\u0430\u044f \u0434\u043e \u0433\u0435\u043d\u0438\u0430\u043b\u044c\u043d\u043e\u0441\u0442\u0438: \u0437\u0430\u043f\u0438\u0441\u0430\u0442\u044c \u0438 \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442 \u0440\u0430\u0431\u043e\u0442\u044b, \u0438 \u043d\u0430\u043c\u0435\u0440\u0435\u043d\u0438\u0435 \u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u044c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0432 \u043e\u0434\u043d\u043e\u0439 \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u0438. \u041e\u0431\u0435 \u0442\u0430\u0431\u043b\u0438\u0446\u044b \u2014 \u0432 \u043e\u0434\u043d\u043e\u0439 \u0431\u0430\u0437\u0435. \u041e\u0434\u043d\u0430 ACID-\u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u044f. \u041b\u0438\u0431\u043e \u043e\u0431\u0435 \u0437\u0430\u043f\u0438\u0441\u0438 \u0437\u0430\u043a\u043e\u043c\u043c\u0438\u0447\u0435\u043d\u044b, \u043b\u0438\u0431\u043e \u043e\u0431\u0435 \u043e\u0442\u043a\u0430\u0447\u0435\u043d\u044b.\u0412\u0430\u043c \u043d\u0435 \u043d\u0443\u0436\u043d\u043e \u043f\u0438\u0441\u0430\u0442\u044c \u0434\u0438\u0441\u043f\u0435\u0442\u0447\u0435\u0440 outbox \u0438 \u0442\u0430\u0431\u043b\u0438\u0446\u0443 \u0440\u0443\u043a\u0430\u043c\u0438. \u041e\u043d\u043e \u0443\u0436\u0435 \u0434\u0430\u0432\u043d\u043e \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043d\u043e \u0432 \u0441\u043e\u0442\u043d\u044f\u0445 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a. \u041d\u0430\u043f\u0440\u0438\u043c\u0435\u0440 ZeroAlloc.Outbox. \u0412\u0441\u0451, \u0447\u0442\u043e \u043e\u0442 \u0432\u0430\u0441 \u0442\u0440\u0435\u0431\u0443\u0435\u0442\u0441\u044f \u2014 \u044d\u0442\u043e \u0437\u0430\u0440\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0441\u0435\u0440\u0432\u0438\u0441\u044b \u0432 DI \u0438 \u043d\u0430\u043f\u0438\u0441\u0430\u0442\u044c \u043a\u0440\u043e\u0448\u0435\u0447\u043d\u044b\u0439 \u043a\u043b\u0430\u0441\u0441-\u0430\u0434\u0430\u043f\u0442\u0435\u0440 \u0434\u043b\u044f \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0438 \u0432 Kafka.\u0412\u043e\u0442 \u043a\u0430\u043a \u0432\u044b\u0433\u043b\u044f\u0434\u0438\u0442 \u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0430 \u0432 Program.cs:\/\/ 1. \u0420\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u0443\u0435\u043c \u0441\u0430\u043c Outbox \u0438\u0437 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0438 ZeroAlloc.Outboxbuilder.Services.AddOutbox(options =&gt;{    options.PollingInterval = TimeSpan.FromMilliseconds(100); \/\/ \u0414\u043b\u044f \u0442\u0435\u0441\u0442\u043e\u0432    options.BatchSize = 50;    options.MaxAttempts = 3;}).WithEfCore&lt;AppDbContext&gt;().AddMessageOutbox();\/\/ 2. \u0420\u0435\u0433\u0438\u0441\u0442\u0440\u0438\u0440\u0443\u0435\u043c \u043d\u0430\u0448 \u0430\u0434\u0430\u043f\u0442\u0435\u0440, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043f\u0440\u043e\u0441\u0442\u043e \u0434\u0435\u0440\u0433\u0430\u0435\u0442 Kafkabuilder.Services.AddTransient&lt;IOutboxDispatcher&lt;Message&gt;, OutboxDispatcher&gt;();\u0418 \u0441\u0430\u043c \u0430\u0434\u0430\u043f\u0442\u0435\u0440 \u2014 5 \u0441\u0442\u0440\u043e\u043a \u043a\u043e\u0434\u0430, \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a\u0430 \u0441\u0430\u043c\u0430 \u0431\u0435\u0440\u0435\u0442 \u043d\u0430 \u0441\u0435\u0431\u044f \u0444\u043e\u043d\u043e\u0432\u044b\u0439 \u043e\u043f\u0440\u043e\u0441, \u0431\u0430\u0442\u0447\u0438\u043d\u0433, \u0440\u0435\u0442\u0440\u0430\u0438 \u0438 \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u043e\u043d\u043d\u043e\u0441\u0442\u044c:public class OutboxDispatcher(IProducer&lt;int, Message&gt; producer) : IOutboxDispatcher&lt;Message&gt;{    public async ValueTask DispatchAsync(Message message, CancellationToken ct)    =&gt; await producer.ProduceAsync(KafkaConsumer.Topic, new()    {        Timestamp = new(message.CreatedAt),        Key = message.Id,        Value = message    }, ct);}\u0412 \u043a\u043e\u0434\u0435 \u044d\u043d\u0434\u043f\u043e\u0438\u043d\u0442\u0430 \u043c\u044b \u043f\u0440\u043e\u0441\u0442\u043e \u0438\u043d\u0436\u0435\u043a\u0442\u0438\u043c IOutboxWriter&lt;Message&gt; \u0438 \u043f\u0438\u0448\u0435\u043c \u0432 \u0442\u043e\u0439 \u0436\u0435 \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u0438:app.MapPost(&#171;\/outbox&#187;, async (Message dto, AppDbContext db, IOutboxWriter&lt;Message&gt; outbox, &#8230;) =&gt;{    var id = await db.Database.CreateExecutionStrategy().ExecuteInTransactionAsync(async (ct) =&gt;    {        Message msg = new() { Content = dto.Content, CreatedAt = DateTime.UtcNow };        db.Messages.Add(msg);        await db.SaveChangesAsync(ct);                \/\/ \u2190 \u041f\u0438\u0448\u0435\u043c \u0432 outbox \u0432 \u0422\u041e\u0419 \u0416\u0415 \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u0438. ZeroAlloc.Outbox \u0441\u0430\u043c \u0432\u0441\u0451 \u0441\u043e\u0445\u0440\u0430\u043d\u0438\u0442        await outbox.WriteAsync(msg, ct: ct);              return msg.Id;    }, ct =&gt; Task.FromResult(false), ct);    &#8230;});\u0441\u0445\u0435\u043c\u0430 2\u041f\u0440\u043e\u0431\u043b\u0435\u043c\u0430 dual write \u0440\u0435\u0448\u0435\u043d\u0430. \u041d\u043e \u0432\u0437\u0430\u043c\u0435\u043d \u043c\u044b \u043f\u043e\u043b\u0443\u0447\u0438\u043b\u0438 \u043d\u043e\u0432\u0443\u044e.\u0426\u0435\u043d\u0430 \u0430\u0442\u043e\u043c\u0430\u0440\u043d\u043e\u0441\u0442\u0438\u0426\u0435\u043d\u0430\u0421\u0443\u0442\u044cWrite amplificationINSERT + INSERT + UPDATE \u043d\u0430 \u043a\u0430\u0436\u0434\u043e\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435Vacuum\u041f\u043e\u0441\u0442\u043e\u044f\u043d\u043d\u043e \u043e\u0431\u043d\u043e\u0432\u043b\u044f\u0435\u043c\u0430\u044f outbox-\u0442\u0430\u0431\u043b\u0438\u0446\u0430 \u0433\u0435\u043d\u0435\u0440\u0438\u0440\u0443\u0435\u0442 \u043c\u0451\u0440\u0442\u0432\u044b\u0435 \u043a\u043e\u0440\u0442\u0435\u0436\u0438\u0424\u043e\u043d\u043e\u0432\u044b\u0439 \u0434\u0438\u0441\u043f\u0435\u0442\u0447\u0435\u0440\u0415\u0449\u0451 \u043e\u0434\u0438\u043d \u043f\u0440\u043e\u0446\u0435\u0441\u0441, \u043a\u043e\u043d\u043a\u0443\u0440\u0438\u0440\u0443\u044e\u0449\u0438\u0439 \u0437\u0430 \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u044f \u043a Postgres\u0417\u0430\u0434\u0435\u0440\u0436\u043a\u0430\u0418\u043d\u0442\u0435\u0440\u0432\u0430\u043b \u043e\u043f\u0440\u043e\u0441\u0430. \u041d\u0435 \u043c\u0438\u043b\u043b\u0438\u0441\u0435\u043a\u0443\u043d\u0434\u044b. \u0421\u043e\u0442\u043d\u0438 \u043c\u0438\u043b\u043b\u0438\u0441\u0435\u043a\u0443\u043d\u0434.\u0418 \u0433\u043b\u0430\u0432\u043d\u043e\u0435 \u2014 \u0432\u0441\u044f \u044d\u0442\u0430 \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0430 \u0436\u0438\u0432\u0451\u0442 \u0432\u043d\u0443\u0442\u0440\u0438 \u0442\u043e\u0433\u043e \u0436\u0435 \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u0430 \u0438 \u0442\u043e\u0439 \u0436\u0435 \u0431\u0430\u0437\u044b, \u0447\u0442\u043e \u043e\u0431\u0441\u043b\u0443\u0436\u0438\u0432\u0430\u0435\u0442 \u0431\u0438\u0437\u043d\u0435\u0441-\u043b\u043e\u0433\u0438\u043a\u0443. \u0427\u0430\u0441\u0442\u044b\u0439 \u043f\u043e\u043b\u043b\u0438\u043d\u0433 \u0441\u043e\u0437\u0434\u0430\u0451\u0442 \u043f\u043e\u0441\u0442\u043e\u044f\u043d\u043d\u044b\u0439 \u0444\u043e\u043d\u043e\u0432\u044b\u0439 I\/O \u0434\u0430\u0436\u0435 \u0442\u043e\u0433\u0434\u0430, \u043a\u043e\u0433\u0434\u0430 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u043d\u0435\u0442.\u0413\u043b\u0430\u0432\u0430 4. Debezium. \u0412\u044b\u043d\u043e\u0441\u0438\u043c \u0431\u043e\u043b\u044c \u0437\u0430 \u043f\u0440\u0435\u0434\u0435\u043b\u044b \u0441\u0435\u0440\u0432\u0438\u0441\u0430\u0412\u0441\u044e \u044d\u0442\u0443 \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0443 \u043d\u0435 \u043e\u0431\u044f\u0437\u0430\u0442\u0435\u043b\u044c\u043d\u043e \u0434\u0435\u0440\u0436\u0430\u0442\u044c \u0432 \u0442\u043e\u043c \u0436\u0435 \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u0435 \u0438 \u043f\u043e\u0441\u0442\u043e\u044f\u043d\u043d\u043e \u0434\u0435\u0440\u0433\u0430\u0442\u044c \u0431\u0430\u0437\u0443. Postgres \u0438 \u0442\u0430\u043a \u043f\u0438\u0448\u0435\u0442 \u043a\u0430\u0436\u0434\u043e\u0435 \u0438\u0437\u043c\u0435\u043d\u0435\u043d\u0438\u0435 \u0432 WAL (Write-Ahead Log).  Debezium \u2014 \u044d\u0442\u043e Kafka Connect \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0440, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0447\u0438\u0442\u0430\u0435\u0442 WAL \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e  \u043b\u043e\u0433\u0438\u0447\u0435\u0441\u043a\u043e\u0439 \u0440\u0435\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u0438 \u0438 \u043f\u0443\u0431\u043b\u0438\u043a\u0443\u0435\u0442 \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442 \u0432 Kafka-\u0442\u043e\u043f\u0438\u043a. \u041f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0435 \u0434\u0435\u043b\u0430\u0435\u0442 \u0442\u043e\u043b\u044c\u043a\u043e INSERT. Outbox \u043d\u0435 \u043d\u0443\u0436\u0435\u043d. \u0412\u0441\u044e \u0440\u0430\u0431\u043e\u0442\u0443 \u043f\u043e \u043d\u0430\u0434\u0451\u0436\u043d\u043e\u0439 \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0435 \u0431\u0435\u0440\u0451\u0442 \u043d\u0430 \u0441\u0435\u0431\u044f \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u044b\u0439 \u043f\u0440\u043e\u0446\u0435\u0441\u0441.\u0441\u0445\u0435\u043c\u0430 3\u041e\u043f\u0440\u043e\u0441 \u0441\u043e\u043e\u0431\u0449\u0435\u0441\u0442\u0432\u0430 Debezium 2026 \u0433\u043e\u0434\u0430 \u043f\u043e\u043a\u0430\u0437\u0430\u043b, \u0447\u0442\u043e 91.3% \u0440\u0435\u0441\u043f\u043e\u043d\u0434\u0435\u043d\u0442\u043e\u0432 \u0443\u0436\u0435 \u0430\u043a\u0442\u0438\u0432\u043d\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044e\u0442 \u0435\u0433\u043e \u0432 \u043f\u0440\u043e\u0434\u0435 (\u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u044b \u043e\u043f\u0440\u043e\u0441\u0430), \u0430 \u0441\u043f\u0438\u0441\u043e\u043a \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u0435\u0439 \u0432\u043a\u043b\u044e\u0447\u0430\u0435\u0442 \u043e\u0440\u0433\u0430\u043d\u0438\u0437\u0430\u0446\u0438\u0438 \u0440\u0430\u0437\u043d\u043e\u0433\u043e \u043c\u0430\u0441\u0448\u0442\u0430\u0431\u0430. \u0412\u044b\u0433\u043b\u044f\u0434\u0438\u0442 \u0442\u0430\u043a, \u0447\u0442\u043e \u0440\u0435\u0448\u0435\u043d\u0438\u044e \u043c\u043e\u0436\u043d\u043e \u0434\u043e\u0432\u0435\u0440\u044f\u0442\u044c.\u041a\u043e\u043d\u0444\u0438\u0433\u0443\u0440\u0430\u0446\u0438\u044f \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0440\u0430:{  &#171;config&#187;: {    &#171;connector.class&#187;: &#171;io.debezium.connector.postgresql.PostgresConnector&#187;,    &#171;table.include.list&#187;: &#171;public.messages&#187;,    &#171;plugin.name&#187;: &#171;pgoutput&#187;,    &#171;slot.name&#187;: &#171;debezium_slot&#187;,    &#171;publication.name&#187;: &#171;debezium_publication&#187;,    &#171;slot.drop.on.stop&#187;: &#171;true&#187;,    &#171;snapshot.mode&#187;: &#171;no_data&#187;,    &#171;poll.interval.ms&#187;: &#171;100&#187;  }}\u0412\u0430\u0436\u043d\u044b\u0435 \u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0438:slot.drop.on.stop: true \u2014 \u0431\u0435\u0437 \u044d\u0442\u043e\u0433\u043e \u043f\u0440\u0438 \u0443\u0434\u0430\u043b\u0435\u043d\u0438\u0438 \u043a\u043e\u043d\u043d\u0435\u043a\u0442\u043e\u0440\u0430 \u0441\u043b\u043e\u0442 \u043e\u0441\u0442\u0430\u043d\u0435\u0442\u0441\u044f \u0432\u0438\u0441\u0435\u0442\u044c \u0438 \u0431\u0443\u0434\u0435\u0442 \u043a\u043e\u043f\u0438\u0442\u044c WAL, \u043f\u043e\u043a\u0430 \u043d\u0435 \u043a\u043e\u043d\u0447\u0438\u0442\u0441\u044f \u0434\u0438\u0441\u043a. \u041f\u043e\u0434\u0440\u043e\u0431\u043d\u0435\u0435 \u043e \u0442\u043e\u043c, \u043a\u0430\u043a \u043d\u0430\u0441\u0442\u0440\u0430\u0438\u0432\u0430\u0442\u044c \u0440\u0435\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u044e \u0438 \u0430\u0434\u043c\u0438\u043d\u0438\u0441\u0442\u0440\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0441\u043b\u043e\u0442\u044b.poll.interval.ms: 100 \u2014 \u043f\u043e \u0443\u043c\u043e\u043b\u0447\u0430\u043d\u0438\u044e 500 \u043c\u0441. \u041d\u0443\u0436\u043d\u043e \u0434\u043b\u044f \u0442\u0435\u0441\u0442\u043e\u0432.\u041c\u044b \u0440\u0435\u0448\u0438\u043b\u0438 \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u0443 \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438 \u043d\u0430 \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0435. \u041c\u044b \u043d\u0435 \u0440\u0435\u0448\u0438\u043b\u0438 \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u0443 \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u0430 \u0434\u0432\u0438\u0436\u0443\u0449\u0438\u0445\u0441\u044f \u0447\u0430\u0441\u0442\u0435\u0439: \u0442\u0435\u043f\u0435\u0440\u044c \u0443 \u043d\u0430\u0441 Postgres, Kafka \u0438 \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u0430\u044f JVM \u0434\u043b\u044f Kafka Connect.\u0413\u043b\u0430\u0432\u0430 5. \u0421\u0442\u043e\u043f. \u0410 \u0437\u0430\u0447\u0435\u043c Kafka \u0432 \u044d\u0442\u043e\u0439 \u0441\u0445\u0435\u043c\u0435?\u041f\u043e\u0441\u043c\u043e\u0442\u0440\u0438\u0442\u0435 \u0435\u0449\u0451 \u0440\u0430\u0437 \u043d\u0430 \u0434\u0438\u0430\u0433\u0440\u0430\u043c\u043c\u0443 \u0433\u043b\u0430\u0432\u044b 4. Debezium \u0447\u0438\u0442\u0430\u0435\u0442 WAL, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 Postgres \u043f\u0438\u0448\u0435\u0442 \u0432 \u043b\u044e\u0431\u043e\u043c \u0441\u043b\u0443\u0447\u0430\u0435. \u0415\u0434\u0438\u043d\u0441\u0442\u0432\u0435\u043d\u043d\u043e\u0435, \u0447\u0442\u043e \u0440\u0435\u0430\u043b\u044c\u043d\u043e \u0434\u0435\u043b\u0430\u0435\u0442 Kafka \u0432 \u044d\u0442\u043e\u0439 \u043a\u043e\u043d\u043a\u0440\u0435\u0442\u043d\u043e\u0439 \u0441\u0445\u0435\u043c\u0435 \u2014 \u044d\u0442\u043e \u0440\u0435\u0442\u0440\u0430\u043d\u0441\u043b\u0438\u0440\u0443\u0435\u0442 \u0442\u043e, \u0447\u0442\u043e \u0443\u0436\u0435 \u043b\u0435\u0436\u0438\u0442 \u0432 WAL, \u0435\u0449\u0451 \u0447\u0435\u0440\u0435\u0437 \u043e\u0434\u0438\u043d \u0441\u0435\u0442\u0435\u0432\u043e\u0439 \u0445\u043e\u043f.WAL \u2014 \u044d\u0442\u043e \u043f\u043e\u0441\u043b\u0435\u0434\u043e\u0432\u0430\u0442\u0435\u043b\u044c\u043d\u044b\u0439, append-only \u043b\u043e\u0433 \u0441 \u043d\u0435\u0437\u0430\u0432\u0438\u0441\u0438\u043c\u044b\u043c\u0438 \u0447\u0438\u0442\u0430\u0442\u0435\u043b\u044f\u043c\u0438, \u043a\u0430\u0436\u0434\u044b\u0439 \u0438\u0437 \u043a\u043e\u0442\u043e\u0440\u044b\u0445 \u0445\u0440\u0430\u043d\u0438\u0442 \u0441\u0432\u043e\u044e \u043f\u043e\u0437\u0438\u0446\u0438\u044e. \u041e\u043f\u0438\u0448\u0438\u0442\u0435 Kafka \u0447\u0435\u043b\u043e\u0432\u0435\u043a\u0443, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043d\u0435 \u0437\u043d\u0430\u0435\u0442, \u0447\u0442\u043e \u044d\u0442\u043e Kafka, \u2014 \u0432\u044b \u0442\u043e\u043b\u044c\u043a\u043e \u0447\u0442\u043e \u043e\u043f\u0438\u0441\u0430\u043b\u0438 WAL.KafkaPostgreSQLTopic\u0422\u0430\u0431\u043b\u0438\u0446\u0430Partition + \u0444\u0438\u043b\u044c\u0442\u0440PUBLICATIONConsumer + offsetReplication slotBrokerWAL + pgoutputProduceINSERTConsume\u0427\u0442\u0435\u043d\u0438\u0435 \u043f\u043e\u0442\u043e\u043a\u0430 \u0440\u0435\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u0438\u0415\u0441\u043b\u0438 \u043e\u0431\u0430 \u043f\u043e\u0442\u0440\u0435\u0431\u0438\u0442\u0435\u043b\u044f \u0441\u043e\u0431\u044b\u0442\u0438\u044f \u2014 \u0432\u0430\u0448 \u043a\u043e\u0434, \u0442\u043e Kafka \u0432 \u044d\u0442\u043e\u0439 \u0441\u0445\u0435\u043c\u0435 \u2014 \u044d\u0442\u043e \u043f\u043b\u0430\u0442\u0430 \u0437\u0430 \u0440\u0435\u0442\u0440\u0430\u043d\u0441\u043b\u044f\u0446\u0438\u044e \u0442\u043e\u0433\u043e, \u0447\u0442\u043e \u0443\u0436\u0435 \u0441\u0443\u0449\u0435\u0441\u0442\u0432\u0443\u0435\u0442. INSERT \u0443\u0436\u0435 \u043f\u043e\u043f\u0430\u043b \u0432 WAL. \u041e\u0442\u0434\u0435\u043b\u044c\u043d\u043e\u0433\u043e \u00ab\u043e\u0442\u043f\u0440\u0430\u0432\u0438\u0442\u044c \u0432 \u043e\u0447\u0435\u0440\u0435\u0434\u044c\u00bb \u043f\u0440\u043e\u0441\u0442\u043e \u043d\u0435 \u0442\u0440\u0435\u0431\u0443\u0435\u0442\u0441\u044f:\u0441\u0445\u0435\u043c\u0430 4\u041d\u043e\u043b\u044c write amplification. \u041d\u043e\u043b\u044c outbox-\u0442\u0430\u0431\u043b\u0438\u0446. \u041d\u0435\u0442 \u0444\u043e\u043d\u043e\u0432\u044b\u0445 \u0434\u0438\u0441\u043f\u0435\u0442\u0447\u0435\u0440\u043e\u0432. \u041d\u0435\u0442 \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u043e\u0439 JVM \u0434\u043b\u044f Kafka Connect.\u0413\u043b\u0430\u0432\u0430 6. \u0427\u0438\u0442\u0430\u0435\u043c \u043b\u043e\u0433\u0438\u0447\u0435\u0441\u043a\u0443\u044e \u0440\u0435\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u044e\u041d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0430 \u043d\u0430 \u0441\u0442\u043e\u0440\u043e\u043d\u0435 \u0411\u0414, \u043b\u0443\u0447\u0448\u0435 \u043f\u0440\u044f\u043c\u043e \u0432 \u043c\u0438\u0433\u0440\u0430\u0446\u0438\u0438:CREATE PUBLICATION rep_pub FOR TABLE messages;SELECT * FROM pg_create_logical_replication_slot(&#8216;rep_slot&#8217;, &#8216;pgoutput&#8217;);\u0414\u043b\u044f \u0447\u0442\u0435\u043d\u0438\u044f \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u043c Npgsql.Replication \u2014 \u0447\u0430\u0441\u0442\u044c \u0448\u0442\u0430\u0442\u043d\u043e\u0433\u043e \u0434\u0440\u0430\u0439\u0432\u0435\u0440\u0430. \u041d\u0438\u043a\u0430\u043a\u0438\u0445 \u0441\u0442\u043e\u0440\u043e\u043d\u043d\u0438\u0445 \u0431\u0438\u0431\u043b\u0438\u043e\u0442\u0435\u043a:await using var conn = new LogicalReplicationConnection(connectionString);await conn.Open(stoppingToken);var slot = new PgOutputReplicationSlot(&#171;rep_slot&#187;);await foreach (var message in conn.StartReplication(    slot, new PgOutputReplicationOptions(&#171;rep_pub&#187;, PgOutputProtocolVersion.V4, binary: true),    stoppingToken)){    if (message is InsertMessage insertMessage)    {        Message msg = await ReadMessageAsync(insertMessage, stoppingToken);        completions.Complete(msg.Id, msg);    }    conn.SetReplicationStatus(message.WalEnd);  \/\/ \u043e\u0431\u044f\u0437\u0430\u0442\u0435\u043b\u044c\u043d\u043e!    await conn.SendStatusUpdate(stoppingToken);}\u041f\u0440\u0438\u043c\u0435\u0440 \u0447\u0442\u0435\u043d\u0438\u044f \u043b\u043e\u0433\u0438\u0447\u0435\u0441\u043a\u043e\u0439 \u0440\u0435\u043f\u043b\u0438\u043a\u0430\u0446\u0438\u0438 Postgres \u044f \u0443\u0436\u0435 \u043f\u0440\u0438\u0432\u043e\u0434\u0438\u043b \u0432 \u0441\u0442\u0430\u0442\u044c\u0435 \u0412\u0430\u0448 \u043a\u044d\u0448 \u0432 Redis \u043d\u0435\u044d\u0444\u0444\u0435\u043a\u0442\u0438\u0432\u0435\u043d, \u0447\u0442\u043e \u0441 \u044d\u0442\u0438\u043c \u0434\u0435\u043b\u0430\u0442\u044c?\u041a\u043e\u0434&#8230;<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[],"tags":[],"class_list":["post-494600","post","type-post","status-publish","format-standard","hentry"],"_links":{"self":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/494600","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=494600"}],"version-history":[{"count":0,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/494600\/revisions"}],"wp:attachment":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=494600"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=494600"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=494600"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}