{"id":468352,"date":"2025-07-23T15:02:11","date_gmt":"2025-07-23T15:02:11","guid":{"rendered":"http:\/\/savepearlharbor.com\/?p=468352"},"modified":"-0001-11-30T00:00:00","modified_gmt":"-0001-11-29T21:00:00","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=468352","title":{"rendered":"Apache Kafka \u0432 \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u044f\u0445 \u0438\u043b\u0438 \u043a\u0430\u043a \u043d\u0430\u0434\u0435\u0436\u043d\u043e \u0434\u043e\u0441\u0442\u0430\u0432\u0438\u0442\u044c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435<\/span>"},"content":{"rendered":"
<\/div>\n
\n
\n
\n
\n

\u0410\u0432\u0442\u043e\u0440 \u0441\u0442\u0430\u0442\u044c\u0438: \u0421\u0435\u0440\u0433\u0435\u0439 \u041f\u0440\u043e\u0449\u0430\u0435\u0432<\/em><\/strong> @sproshchaev<\/a>
\u0420\u0443\u043a\u043e\u0432\u043e\u0434\u0438\u0442\u0435\u043b\u044c \u043d\u0430\u043f\u0440\u0430\u0432\u043b\u0435\u043d\u0438\u044f Java\u2011\u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u0432\u00a0FinTech<\/em><\/p>\n

\u0412\u0432\u0435\u0434\u0435\u043d\u0438\u0435 <\/strong><\/p>\n

Apache Kafka\u00a0\u2014 \u044d\u0442\u043e \u043e\u0441\u043d\u043e\u0432\u0430 \u0441\u043e\u0432\u0440\u0435\u043c\u0435\u043d\u043d\u044b\u0445 \u0440\u0430\u0441\u043f\u0440\u0435\u0434\u0435\u043b\u0435\u043d\u043d\u044b\u0445 \u0441\u0438\u0441\u0442\u0435\u043c, \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u044e\u0449\u0438\u0439 \u0442\u0440\u0438\u043b\u043b\u0438\u043e\u043d\u044b \u0441\u043e\u0431\u044b\u0442\u0438\u0439 \u0435\u0436\u0435\u0434\u043d\u0435\u0432\u043d\u043e. \u041d\u043e\u00a0\u0447\u0442\u043e\u00a0\u043f\u0440\u043e\u0438\u0441\u0445\u043e\u0434\u0438\u0442, \u0435\u0441\u043b\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043f\u043e\u0442\u0435\u0440\u044f\u043b\u043e\u0441\u044c, \u043f\u0440\u0438\u0448\u043b\u043e \u0434\u0432\u0430\u0436\u0434\u044b \u0438\u043b\u0438\u00a0\u043d\u0430\u0440\u0443\u0448\u0438\u043b\u0430\u0441\u044c \u043b\u043e\u0433\u0438\u043a\u0430 \u0431\u0438\u0437\u043d\u0435\u0441\u2011\u043f\u0440\u043e\u0446\u0435\u0441\u0441\u0430? \u0413\u0430\u0440\u0430\u043d\u0442\u0438\u0438 \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 \u0432\u00a0Kafka\u00a0\u2014 \u044d\u0442\u043e \u0441\u0442\u0440\u0430\u0445\u043e\u0432\u043a\u0430 \u043e\u0442\u00a0\u0445\u0430\u043e\u0441\u0430 \u0432\u00a0\u0443\u0441\u043b\u043e\u0432\u0438\u044f\u0445 \u0432\u044b\u0441\u043e\u043a\u043e\u0439 \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438 \u0438 \u0441\u0431\u043e\u0435\u0432.<\/p>\n

\u0412\u00a0\u044d\u0442\u043e\u0439 \u0441\u0442\u0430\u0442\u044c\u0435 \u043c\u044b \u0440\u0430\u0437\u0431\u0435\u0440\u0435\u043c \u0442\u0440\u0438 \u0432\u0438\u0434\u0430 \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u0439 \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u043d\u0430\u00a0\u043f\u0440\u0438\u043c\u0435\u0440\u0430\u0445.<\/p>\n

\u0427\u0442\u043e\u00a0\u0442\u0430\u043a\u043e\u0435 \u0441\u0435\u043c\u0430\u043d\u0442\u0438\u043a\u0430 \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 \u0438 \u0447\u0442\u043e\u00a0\u0442\u0430\u043a\u043e\u0435 \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u044f \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 \u0432\u00a0Kafka?<\/h3>\n

\u0421\u0435\u043c\u0430\u043d\u0442\u0438\u043a\u0430 \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 (Delivery Semantics) \u0438 \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u044f \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 (Delivery Guarantee) \u0432\u00a0Apache Kafka \u0441\u0432\u044f\u0437\u0430\u043d\u044b, \u043d\u043e\u00a0\u044d\u0442\u043e \u043d\u0435\u00a0\u043e\u0434\u043d\u043e \u0438 \u0442\u043e\u00a0\u0436\u0435.<\/p>\n

\u0421\u0435\u043c\u0430\u043d\u0442\u0438\u043a\u0430 \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 (Delivery Semantics) \u044d\u0442\u043e \u043f\u0440\u0430\u0432\u0438\u043b\u0430, \u043e\u043f\u0440\u0435\u0434\u0435\u043b\u044f\u044e\u0449\u0438\u0435, \u0441\u043a\u043e\u043b\u044c\u043a\u043e \u0440\u0430\u0437 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0431\u0443\u0434\u0435\u0442 \u0434\u043e\u0441\u0442\u0430\u0432\u043b\u0435\u043d\u043e \u043f\u043e\u0442\u0440\u0435\u0431\u0438\u0442\u0435\u043b\u044e. \u042d\u0442\u043e \u0442\u0435\u0445\u043d\u0438\u0447\u0435\u0441\u043a\u0430\u044f \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044f \u043f\u043e\u0432\u0435\u0434\u0435\u043d\u0438\u044f \u0441\u0438\u0441\u0442\u0435\u043c\u044b \u0432\u00a0\u0441\u043b\u0443\u0447\u0430\u0435 \u0441\u0431\u043e\u0435\u0432, \u043f\u043e\u0432\u0442\u043e\u0440\u043d\u044b\u0445 \u043e\u0442\u043f\u0440\u0430\u0432\u043e\u043a \u0438\u043b\u0438\u00a0\u043f\u0430\u0440\u0430\u043b\u043b\u0435\u043b\u044c\u043d\u043e\u0439 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438. \u0418 \u0437\u0434\u0435\u0441\u044c \u043e\u043f\u0440\u0435\u0434\u0435\u043b\u0435\u043d\u044b \u0442\u0440\u0438 \u0432\u0430\u0440\u0438\u0430\u043d\u0442\u0430: At\u2011Most\u2011Once, At\u2011Least\u2011Once, Exactly\u2011Once:<\/p>\n

<\/figure>\n

\u0413\u0430\u0440\u0430\u043d\u0442\u0438\u044f \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 (Delivery Guarantee)\u00a0\u2014 \u044d\u0442\u043e \u043e\u0431\u0435\u0449\u0430\u043d\u0438\u0435 \u0441\u0438\u0441\u0442\u0435\u043c\u044b \u043e\u0431\u0435\u0441\u043f\u0435\u0447\u0438\u0442\u044c \u043e\u043f\u0440\u0435\u0434\u0435\u043b\u0435\u043d\u043d\u044b\u0439 \u0443\u0440\u043e\u0432\u0435\u043d\u044c \u043d\u0430\u0434\u0435\u0436\u043d\u043e\u0441\u0442\u0438. \u042d\u0442\u043e \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0434\u043e\u0441\u0442\u0438\u0433\u0430\u0435\u0442\u0441\u044f \u0447\u0435\u0440\u0435\u0437 \u043f\u0440\u0438\u043c\u0435\u043d\u0435\u043d\u0438\u0435 \u043a\u043e\u043d\u043a\u0440\u0435\u0442\u043d\u043e\u0439 \u0441\u0435\u043c\u0430\u043d\u0442\u0438\u043a\u0438. \u0422\u0430\u043a \u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440 \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u044f \u00ab\u043d\u0435 \u043f\u043e\u0442\u0435\u0440\u044f\u0442\u044c \u0434\u0430\u043d\u043d\u044b\u0435\u00bb \u0440\u0435\u0430\u043b\u0438\u0437\u0443\u0435\u0442\u0441\u044f \u0447\u0435\u0440\u0435\u0437 \u0441\u0435\u043c\u0430\u043d\u0442\u0438\u043a\u0443 At\u2011Least\u2011Once, \u0430\u00a0\u0433\u0430\u0440\u0430\u043d\u0442\u0438\u044f \u00ab\u0442\u043e\u0447\u043d\u043e\u0435 \u0432\u044b\u043f\u043e\u043b\u043d\u0435\u043d\u0438\u0435 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0438\u00bb \u0442\u0440\u0435\u0431\u0443\u0435\u0442 \u0441\u0435\u043c\u0430\u043d\u0442\u0438\u043a\u0438 Exactly\u2011Once.<\/p>\n

\u0422\u0430\u043a\u0438\u043c \u043e\u0431\u0440\u0430\u0437\u043e\u043c \u0441\u0435\u043c\u0430\u043d\u0442\u0438\u043a\u0430\u00a0\u2014 \u044d\u0442\u043e \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0432\u044b \u043d\u0430\u0441\u0442\u0440\u0430\u0438\u0432\u0430\u0435\u0442\u0435 (\u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u0438 Kafka), \u0430\u00a0\u0433\u0430\u0440\u0430\u043d\u0442\u0438\u044f\u00a0\u2014 \u044d\u0442\u043e \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0432\u0438\u0434\u0438\u0442 \u0431\u0438\u0437\u043d\u0435\u0441 \u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u00ab\u043f\u043b\u0430\u0442\u0435\u0436 \u0437\u0430\u0447\u0438\u0441\u043b\u0438\u0442\u0441\u044f \u0440\u043e\u0432\u043d\u043e \u043e\u0434\u0438\u043d \u0440\u0430\u0437\u00bb. <\/p>\n

\u0414\u0430\u0432\u0430\u0439\u0442\u0435 \u0440\u0430\u0437\u0431\u0435\u0440\u0435\u043c \u0442\u0440\u0438 \u0432\u0430\u0440\u0438\u0430\u043d\u0442\u0430 \u0441\u0435\u043c\u0430\u043d\u0442\u0438\u043a\u0438 \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 \u0431\u043e\u043b\u0435\u0435 \u043f\u043e\u0434\u0440\u043e\u0431\u043d\u043e.<\/p>\n

1. At\u2011Most\u2011Once (\u043d\u0435 \u0431\u043e\u043b\u0435\u0435 \u043e\u0434\u043d\u043e\u0433\u043e \u0440\u0430\u0437\u0430):<\/strong> \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043c\u043e\u0436\u0435\u0442\u00a0\u0431\u044b\u0442\u044c \u043f\u043e\u0442\u0435\u0440\u044f\u043d\u043e, \u043d\u043e\u00a0\u043d\u0438\u043a\u043e\u0433\u0434\u0430 \u043d\u0435\u00a0\u0434\u0443\u0431\u043b\u0438\u0440\u0443\u0435\u0442\u0441\u044f. \u041f\u0440\u043e\u0434\u044e\u0441\u0435\u0440 \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u0442 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0431\u0435\u0437\u00a0\u043f\u043e\u0434\u0442\u0432\u0435\u0440\u0436\u0434\u0435\u043d\u0438\u044f. \u041a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440 \u0430\u0432\u0442\u043e\u043c\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u043a\u043e\u043c\u043c\u0438\u0442\u0438\u0442 \u043e\u0444\u0441\u0435\u0442 \u0434\u043e\u00a0\u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f. \u0415\u0441\u043b\u0438 \u043a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440 \u0443\u043f\u0430\u0434\u0451\u0442 \u0434\u043e\u00a0\u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438, \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0431\u0443\u0434\u0435\u0442 \u043f\u043e\u0442\u0435\u0440\u044f\u043d\u043e. \u042d\u0442\u043e\u0442 \u0432\u0438\u0434 \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u0432\u00a0\u0441\u0438\u0441\u0442\u0435\u043c\u0430\u0445 \u0433\u0434\u0435 \u043f\u043e\u0442\u0435\u0440\u044f \u0434\u0430\u043d\u043d\u044b\u0445 \u043d\u0435\u00a0\u044f\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u044b\u043c\u00a0\u2014 \u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u043c\u0435\u0442\u0440\u0438\u043a\u0438, \u043b\u043e\u0433\u0438). <\/p>\n

2. At\u2011Least\u2011Once (\u043d\u0435 \u043c\u0435\u043d\u0435\u0435 \u043e\u0434\u043d\u043e\u0433\u043e \u0440\u0430\u0437\u0430):<\/strong> \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043d\u0438\u043a\u043e\u0433\u0434\u0430 \u043d\u0435\u00a0\u0442\u0435\u0440\u044f\u0435\u0442\u0441\u044f, \u043d\u043e\u00a0\u043c\u043e\u0436\u0435\u0442\u00a0\u0431\u044b\u0442\u044c \u0434\u0443\u0431\u043b\u0438\u0440\u043e\u0432\u0430\u043d\u043e. \u041f\u0440\u043e\u0434\u044e\u0441\u0435\u0440 \u0432\u043a\u043b\u044e\u0447\u0430\u0435\u0442 \u043f\u043e\u0434\u0442\u0432\u0435\u0440\u0436\u0434\u0435\u043d\u0438\u044f \u0438 \u043f\u043e\u0432\u0442\u043e\u0440\u043d\u044b\u0435 \u043f\u043e\u043f\u044b\u0442\u043a\u0438. \u041a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440 \u0432\u0440\u0443\u0447\u043d\u0443\u044e \u043a\u043e\u043c\u043c\u0438\u0442\u0438\u0442 \u043e\u0444\u0441\u0435\u0442 \u043f\u043e\u0441\u043b\u0435 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438. \u0412\u00a0\u044d\u0442\u043e\u043c \u0441\u043b\u0443\u0447\u0430\u0435 \u043c\u043e\u0436\u0435\u0442 \u0432\u043e\u0437\u043d\u0438\u043a\u043d\u0443\u0442\u044c \u0434\u0443\u0431\u043b\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u043f\u0440\u0438\u00a0\u043f\u043e\u0432\u0442\u043e\u0440\u043d\u043e\u0439 \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0435 \u0438\u043b\u0438\u00a0\u0441\u0431\u043e\u0435. \u042d\u0442\u0443 \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u044e \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 \u043b\u0443\u0447\u0448\u0435 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c \u0434\u043b\u044f\u00a0\u0441\u0438\u0441\u0442\u0435\u043c, \u0433\u0434\u0435 \u043f\u043e\u0442\u0435\u0440\u044f \u0434\u0430\u043d\u043d\u044b\u0445 \u043d\u0435\u0434\u043e\u043f\u0443\u0441\u0442\u0438\u043c\u0430 (\u043f\u043b\u0430\u0442\u0435\u0436\u0438, \u0437\u0430\u043a\u0430\u0437\u044b). <\/p>\n

3. Exactly\u2011Once (\u0442\u043e\u0447\u043d\u043e \u043e\u0434\u0438\u043d \u0440\u0430\u0437):<\/strong> \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0434\u043e\u0441\u0442\u0430\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u0440\u043e\u0432\u043d\u043e \u043e\u0434\u0438\u043d \u0440\u0430\u0437, \u0434\u0430\u0436\u0435 \u043f\u0440\u0438\u00a0\u0441\u0431\u043e\u044f\u0445. \u041f\u0440\u043e\u0434\u044e\u0441\u0435\u0440 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442 \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u0438 \u0438 \u0438\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u043e\u0441\u0442\u044c. \u041a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440 \u0447\u0438\u0442\u0430\u0435\u0442 \u0442\u043e\u043b\u044c\u043a\u043e \u0437\u0430\u0444\u0438\u043a\u0441\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u0435 \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u0438. \u0412\u00a0\u044d\u0442\u043e\u043c \u0441\u043b\u0443\u0447\u0430\u0435 \u043c\u044b \u043d\u0430\u0433\u0440\u0443\u0436\u0430\u0435\u043c Kafka \u0443\u043f\u0440\u0430\u0432\u043b\u0435\u043d\u0438\u0435\u043c \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u044f\u043c\u0438 \u0438 \u0438\u0437\u2011\u0437\u0430 \u044d\u0442\u043e\u0433\u043e \u0443\u00a0\u043d\u0430\u0441 \u0443\u0432\u0435\u043b\u0438\u0447\u0438\u0432\u0430\u0435\u0442\u0441\u044f \u0432\u0440\u0435\u043c\u044f \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439. \u041f\u043e\u0434\u043e\u0431\u043d\u0443\u044e \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u044e \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 \u0440\u0435\u043a\u043e\u043c\u0435\u043d\u0434\u0443\u0435\u0442\u0441\u044f \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c \u043f\u0440\u0438\u00a0\u043f\u043e\u0441\u0442\u0440\u043e\u0435\u043d\u0438\u0438 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u043a\u0440\u0438\u0442\u0438\u0447\u043d\u044b\u0445 \u043e\u043f\u0435\u0440\u0430\u0446\u0438\u0439 \u0433\u0434\u0435 \u0442\u0440\u0435\u0431\u0443\u0435\u0442\u0441\u044f \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0430 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0441\u0442\u0440\u043e\u0433\u043e \u043e\u0434\u0438\u043d \u0440\u0430\u0437.<\/p>\n

\u041d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0430 \u043f\u0440\u043e\u0435\u043a\u0442\u0430<\/h3>\n

\u0414\u0430\u0432\u0430\u0439\u0442\u0435 \u0440\u0430\u0441\u0441\u043c\u043e\u0442\u0440\u0438\u043c \u043f\u0440\u0438\u043c\u0435\u0440\u044b \u043a\u043e\u043d\u0444\u0438\u0433\u0443\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f \u041f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u043e\u0432 \u0438 \u041a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u043e\u0432 \u0434\u043b\u044f\u00a0\u0432\u0441\u0435\u0445 \u0442\u0440\u0435\u0445 \u0432\u0430\u0440\u0438\u0430\u043d\u0442\u043e\u0432 \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u0439 \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439.<\/p>\n

\u0414\u043b\u044f\u00a0\u043c\u0438\u043d\u0438\u043c\u0438\u0437\u0430\u0446\u0438\u0438 \u043a\u043e\u0434\u0430 \u0431\u0443\u0434\u0435\u043c \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c Java \u0438 Spring Framework \u0438 \u043f\u043e\u0434\u043a\u043b\u044e\u0447\u0438\u043c \u0434\u0432\u0435 \u0437\u0430\u0432\u0438\u0441\u0438\u043c\u043e\u0441\u0442\u0438: <\/p>\n

<dependencies>     <dependency>         <groupId>org.springframework.boot<\/groupId>         <artifactId>spring-boot-starter<\/artifactId>     <\/dependency>     <dependency>         <groupId>org.springframework.kafka<\/groupId>         <artifactId>spring-kafka<\/artifactId>     <\/dependency> <\/dependencies><\/code><\/pre>\n
\u041d\u0435\u00a0\u0431\u043e\u043b\u0435\u0435 \u043e\u0434\u043d\u043e\u0433\u043e \u0440\u0430\u0437\u0430 (At\u2011Most\u2011Once)<\/strong><\/p>\n
\u041f\u0435\u0440\u0432\u044b\u043c \u043d\u0430\u0441\u0442\u0440\u043e\u0438\u043c \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u044e \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 \u043f\u0440\u0438\u00a0\u043a\u043e\u0442\u043e\u0440\u043e\u0439 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043c\u043e\u0436\u0435\u0442\u00a0\u0431\u044b\u0442\u044c \u043f\u043e\u0442\u0435\u0440\u044f\u043d\u043e, \u043d\u043e\u00a0\u043d\u0435\u00a0\u0434\u0443\u0431\u043b\u0438\u0440\u0443\u0435\u0442\u0441\u044f. \u0414\u043b\u044f\u00a0\u044d\u0442\u043e\u0433\u043e \u043d\u0430\u043c \u043d\u0430\u0434\u043e \u0432\u044b\u043a\u043b\u044e\u0447\u0438\u0442\u044c \u0443\u00a0\u041f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u0430 \u043e\u0436\u0438\u0434\u0430\u043d\u0438\u0435 \u043f\u043e\u0434\u0442\u0432\u0435\u0440\u0436\u0434\u0435\u043d\u0438\u044f \u0437\u0430\u043f\u0438\u0441\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0432\u00a0Kafka \u0438 \u0432\u044b\u043a\u043b\u044e\u0447\u0438\u0442\u044c \u043f\u043e\u0432\u0442\u043e\u0440\u044b \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439:<\/p>\n
@Configuration public class ProducerAMO {       @Bean     public ProducerFactory<String, String> producerFactory() {         Map<String, Object> config = new HashMap<>();         config.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,                                                 \"localhost:9092\");         config.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,                                                 StringSerializer.class);         config.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,                                                 StringSerializer.class);         config.put(ProducerConfig.ACKS_CONFIG, \"0\");          config.put(ProducerConfig.RETRIES_CONFIG, 0);         return new DefaultKafkaProducerFactory<>(config);     }      @Bean     public KafkaTemplate<String, String> kafkaTemplate() {         return new KafkaTemplate<>(producerFactory());     } }  @Service public class ProducerServiceAMO {     @Autowired     private KafkaTemplate<String, String> kafkaTemplate;      public void send(String topic, String message) {         kafkaTemplate.send(topic, message);     } }<\/code><\/pre>\n
\u0414\u043b\u044f\u00a0\u041a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u0430 \u043d\u0430\u043c \u043d\u0443\u0436\u043d\u043e \u0432\u043a\u043b\u044e\u0447\u0438\u0442\u044c \u0430\u0432\u0442\u043e\u043a\u043e\u043c\u043c\u0438\u0442 \u043e\u0444\u0441\u0435\u0442\u043e\u0432:<\/p>\n
@Configuration public class ConsumerAMO {      @Bean     public ConsumerFactory<String, String> consumerFactory() {         Map<String, Object> config = new HashMap<>();   config.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,                                                      \"localhost:9092\");         config.put(ConsumerConfig.GROUP_ID_CONFIG, \"group-amo\");         config.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,                                              StringDeserializer.class);         config.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,                                              StringDeserializer.class);         config.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, true);         config.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, \"earliest\");         return new DefaultKafkaConsumerFactory<>(config);     }      @Bean     public ConcurrentKafkaListenerContainerFactory<String, String>             kafkaListenerContainerFactory() {         ConcurrentKafkaListenerContainerFactory<String, String>              factory =                 new ConcurrentKafkaListenerContainerFactory<>();         factory.setConsumerFactory(consumerFactory());         return factory;     } }  @Service public class ConsumerService_AMO {     @KafkaListener(topics = \"topic-am0\", groupId = \"group-amo\")     public void consume(String message) {         System.out.println(\"Received (At-Most-Once): \" + message);     } }<\/code><\/pre>\n
\u041d\u0435\u00a0\u043c\u0435\u043d\u0435\u0435 \u043e\u0434\u043d\u043e\u0433\u043e \u0440\u0430\u0437\u0430 (At\u2011Least\u2011Once)<\/strong><\/p>\n
\u0412\u0442\u043e\u0440\u044b\u043c \u043f\u0440\u0438\u043c\u0435\u0440\u043e\u043c \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u0438 \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 \u0431\u0443\u0434\u0435\u0442 \u0432\u0430\u0440\u0438\u0430\u043d\u0442 \u0441\u00a0\u0434\u043e\u0441\u0442\u0430\u0432\u043a\u043e\u0439 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u043d\u0435\u00a0\u043c\u0435\u043d\u0435\u0435 \u043e\u0434\u043d\u043e\u0433\u043e \u0440\u0430\u0437\u0430. \u041d\u0430\u043c \u043d\u0443\u0436\u043d\u043e \u043d\u0430\u0441\u0442\u0440\u043e\u0438\u0442\u044c \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u0438\u0435 \u043f\u043e\u0434\u0442\u0432\u0435\u0440\u0436\u0434\u0435\u043d\u0438\u044f \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u041f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u043e\u043c \u043e\u0442\u00a0\u0432\u0441\u0435\u0445 \u0440\u0435\u043f\u043b\u0438\u043a \u0432\u00a0\u043a\u043b\u0430\u0441\u0442\u0435\u0440\u0435 \u0438 \u0443\u0441\u0442\u0430\u043d\u043e\u0432\u0438\u0442\u044c \u043f\u043e\u0432\u0442\u043e\u0440\u044b \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439: <\/p>\n
@Configuration public class ProducerALO {      @Bean     public ProducerFactory<String, String> producerFactory() {         Map<String, Object> config = new HashMap<>();         config.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,                                                     \"localhost:9092\");         config.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,                                                 StringSerializer.class);         config.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,                                                 StringSerializer.class);         config.put(ProducerConfig.ACKS_CONFIG, \"all\");         config.put(ProducerConfig.RETRIES_CONFIG, 3);         return new DefaultKafkaProducerFactory<>(config);     }      @Bean     public KafkaTemplate<String, String> kafkaTemplate() {         return new KafkaTemplate<>(producerFactory());     } }  @Service public class ProducerServiceALO {     @Autowired     private KafkaTemplate<String, String> kafkaTemplate;      public void send(String topic, String message) {         kafkaTemplate.send(topic, message).get();     } }<\/code><\/pre>\n
\u041d\u0430\u00a0\u0441\u0442\u043e\u0440\u043e\u043d\u0435 \u041a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u0430 \u043d\u0430\u043c \u043d\u0443\u0436\u043d\u043e \u0431\u0443\u0434\u0435\u0442 \u043d\u0430\u0441\u0442\u0440\u043e\u0438\u0442\u044c \u0440\u0443\u0447\u043d\u043e\u0439 \u043a\u043e\u043c\u043c\u0438\u0442 \u043e\u0444\u0441\u0435\u0442\u043e\u0432:<\/p>\n
@Configuration public class ConsumerALO {     @Bean     public ConsumerFactory<String, String> consumerFactory() {         Map<String, Object> config = new HashMap<>();         config.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,                                                       \"localhost:9092\");         config.put(ConsumerConfig.GROUP_ID_CONFIG, \"group-alo\");         config.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,                                               StringDeserializer.class);         config.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,                                               StringDeserializer.class);         config.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, false);         config.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, \"earliest\");         return new DefaultKafkaConsumerFactory<>(config);     }  @Bean     public ConcurrentKafkaListenerContainerFactory<String, String>                kafkaListenerContainerFactory() {         ConcurrentKafkaListenerContainerFactory<String, String>          factory = new ConcurrentKafkaListenerContainerFactory<>();         factory.setConsumerFactory(consumerFactory());         factory.getContainerProperties()                .setAckMode(ContainerProperties                                .AckMode.MANUAL_IMMEDIATE);         return factory;     } }  @Service public class ConsumerServiceALO {     @KafkaListener(topics = \"topic-alo\", groupId = \"group-alo\")     public void consume(ConsumerRecord<String, String> record,                           Acknowledgment ack) {         System.out.println(\"Received: \" + record.value());         ack.acknowledge();     } }<\/code><\/pre>\n
\u0422\u043e\u0447\u043d\u043e \u043e\u0434\u0438\u043d \u0440\u0430\u0437 (Exactly\u2011Once)<\/strong><\/p>\n
\u0414\u043b\u044f\u00a0\u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0438 \u044d\u0442\u043e\u0433\u043e \u0432\u0430\u0440\u0438\u0430\u043d\u0442\u0430 \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u0438 \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 \u043d\u0430\u043c \u043d\u0443\u0436\u043d\u043e \u0432\u043a\u043b\u044e\u0447\u0438\u0442\u044c \u0440\u0435\u0436\u0438\u043c \u0438\u0434\u0435\u043c\u043f\u043e\u0442\u0435\u043d\u0442\u043d\u043e\u0441\u0442\u0438 \u0438 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435 \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u0439 \u0443\u00a0\u041f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u0430:<\/p>\n
@Configuration public class ProducerEO {     @Bean     public ProducerFactory<String, String> producerFactory() {         Map<String, Object> config = new HashMap<>();         config.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,                                                        \"localhost:9092\");         config.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,                                                 StringSerializer.class);         config.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,                                                 StringSerializer.class);         config.put(ProducerConfig.ENABLE_IDEMPOTENCE_CONFIG, true);         config.put(ProducerConfig.TRANSACTIONAL_ID_CONFIG, \"tx-001\");         config.put(ProducerConfig.ACKS_CONFIG, \"all\");         return new DefaultKafkaProducerFactory<>(config);     }  @Bean     public KafkaTemplate<String, String> kafkaTemplate() {         KafkaTemplate<String, String> template =                                   new KafkaTemplate<>(producerFactory());         template.setProducerListener(new ProducerListener<String, String>() {             @Override             public void onSuccess(ProducerRecord<String, String> record, RecordMetadata metadata) {                 \/\/ \u0417\u0434\u0435\u0441\u044c \u043c\u044b \u0432\u0441\u0442\u0430\u0432\u0438\u043c \u043b\u043e\u0433\u0438\u043a\u0443 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u0443\u0441\u043f\u0435\u0448\u043d\u043e\u0439 \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0438             }         });         return template;     } }  @Service public class ProducerServiceEO {       @Autowired     private KafkaTemplate<String, String> kafkaTemplate;      public void send(String topic, String message) {         kafkaTemplate.executeInTransaction(operations -> {             operations.send(topic, message);             return null;         });     } }<\/code><\/pre>\n
\u0414\u043b\u044f\u00a0\u041a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u0430 \u043d\u0430\u043c \u043d\u0443\u0436\u043d\u043e \u0443\u0441\u0442\u0430\u043d\u043e\u0432\u0438\u0442\u044c \u0443\u0440\u043e\u0432\u0435\u043d\u044c \u0438\u0437\u043e\u043b\u044f\u0446\u0438\u0438 \u0442\u0440\u0430\u043d\u0437\u0430\u043a\u0446\u0438\u0439 read_committed<\/code>:<\/p>\n
@Configuration public class ConsumerEO {     @Bean     public ConsumerFactory<String, String> consumerFactory() {         Map<String, Object> config = new HashMap<>();         config.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,                                                        \"localhost:9092\");         config.put(ConsumerConfig.GROUP_ID_CONFIG, \"group-eo\");         config.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,                                               StringDeserializer.class);         config.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,                                               StringDeserializer.class);    config.put(ConsumerConfig.ISOLATION_LEVEL_CONFIG,                                                       \"read_committed\");         config.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, \"earliest\");         return new DefaultKafkaConsumerFactory<>(config);     }      @Bean     public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory() {         ConcurrentKafkaListenerContainerFactory<String, String>              factory = new ConcurrentKafkaListenerContainerFactory<>();         factory.setConsumerFactory(consumerFactory());         return factory;     } }  @Service public class ConsumerServiceEO {     @KafkaListener(topics = \"topic-eo\", groupId = \"group-eo\")     public void consume(String message) {         System.out.println(\"Received (Exactly-Once): \" + message);     } }<\/code><\/pre>\n
\u0417\u0430\u043a\u043b\u044e\u0447\u0435\u043d\u0438\u0435 <\/h3>\n
\u0412\u00a0\u044d\u0442\u0438\u0445 \u0443\u0447\u0435\u0431\u043d\u044b\u0445 \u043f\u0440\u0438\u043c\u0435\u0440\u0430\u0445 \u043c\u044b \u0440\u0430\u0441\u0441\u043c\u043e\u0442\u0440\u0435\u043b\u0438 \u0444\u0440\u0430\u0433\u043c\u0435\u043d\u0442\u044b \u043a\u043e\u043d\u0444\u0438\u0433\u0443\u0440\u0430\u0446\u0438\u0438 \u041f\u0440\u043e\u0434\u044e\u0441\u0435\u0440\u0430 \u0438 \u041a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u0430 \u0434\u043b\u044f\u00a0\u0442\u0440\u0435\u0445 \u0440\u0430\u0437\u043b\u0438\u0447\u043d\u044b\u0445 \u0432\u0430\u0440\u0438\u0430\u043d\u0442\u043e\u0432 \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u0439 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u0432\u00a0\u0440\u0430\u0441\u043f\u0440\u0435\u0434\u0435\u043b\u0435\u043d\u043d\u044b\u0445 \u0441\u0438\u0441\u0442\u0435\u043c\u0430\u0445. \u041a\u0430\u043a\u00a0\u043c\u044b \u0432\u0438\u0434\u0438\u043c, \u0447\u0442\u043e\u00a0\u0433\u0430\u0440\u0430\u043d\u0442\u0438\u044f \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 At\u2011Most\u2011Once, \u043f\u0440\u0438\u00a0\u043a\u043e\u0442\u043e\u0440\u043e\u0439 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0434\u043e\u0441\u0442\u0430\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u043d\u0435\u00a0\u0431\u043e\u043b\u0435\u0435 \u043e\u0434\u043d\u043e\u0433\u043e \u0440\u0430\u0437\u0430, \u0438\u043c\u0435\u0435\u0442 \u043d\u0430\u0438\u0432\u044b\u0441\u0448\u0443\u044e \u0441\u043a\u043e\u0440\u043e\u0441\u0442\u044c, \u043d\u043e\u00a0\u043f\u0440\u0438\u00a0\u044d\u0442\u043e\u043c \u043d\u0435\u00a0\u0433\u0430\u0440\u0430\u043d\u0442\u0438\u0440\u0443\u0435\u0442\u0441\u044f \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u0438\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u041a\u043e\u043d\u044c\u044e\u043c\u0435\u0440\u043e\u043c. \u0418\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0435 At\u2011Least\u2011Once \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0435\u0442 \u0434\u043e\u0441\u0442\u0430\u0432\u0438\u0442\u044c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043d\u0435\u00a0\u043c\u0435\u043d\u0435\u0435 \u043e\u0434\u043d\u043e\u0433\u043e \u0440\u0430\u0437\u0430, \u043d\u043e\u00a0\u043f\u0440\u0438\u00a0\u044d\u0442\u043e\u043c \u0434\u043e\u043f\u0443\u0441\u043a\u0430\u0435\u0442 \u0438 \u043d\u0430\u043b\u0438\u0447\u0438\u0435 \u0434\u0443\u0431\u043b\u0438\u043a\u0430\u0442\u043e\u0432. \u0410\u00a0\u0441\u0430\u043c\u044b\u0439 \u0442\u043e\u0447\u043d\u044b\u0439 \u0432\u0430\u0440\u0438\u0430\u043d\u0442\u00a0\u2014 Exactly\u2011Once \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0435\u0442 \u041a\u043e\u043d\u0441\u044c\u044e\u043c\u0435\u0440\u0443 \u043f\u043e\u043b\u0443\u0447\u0438\u0442\u044c \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0442\u043e\u0447\u043d\u043e \u043e\u0434\u0438\u043d \u0440\u0430\u0437, \u043d\u043e\u00a0\u043f\u0440\u0438\u00a0\u044d\u0442\u043e\u043c \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u0441\u0430\u043c\u044b\u0439 \u043c\u0435\u0434\u043b\u0435\u043d\u043d\u044b\u0439 \u0438 \u0441\u0430\u043c\u044b\u0439 \u0441\u043b\u043e\u0436\u043d\u044b\u0439 \u0432\u0430\u0440\u0438\u0430\u043d\u0442 \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438. <\/p>\n
\u041d\u0430\u00a0\u043f\u0440\u0430\u043a\u0442\u0438\u043a\u0435 \u0440\u0435\u043a\u043e\u043c\u0435\u043d\u0434\u0443\u0435\u0442\u0441\u044f \u0432\u044b\u0431\u0438\u0440\u0430\u0442\u044c \u043d\u0430\u0438\u0431\u043e\u043b\u0435\u0435 \u043f\u043e\u0434\u0445\u043e\u0434\u044f\u0449\u0438\u0439 \u0432\u0430\u0440\u0438\u0430\u043d\u0442 \u0433\u0430\u0440\u0430\u043d\u0442\u0438\u0438 \u0434\u043e\u0441\u0442\u0430\u0432\u043a\u0438 \u0434\u043b\u044f\u00a0\u0432\u0430\u0448\u0435\u0439 \u0441\u0438\u0441\u0442\u0435\u043c\u044b, \u0447\u0442\u043e\u0431\u044b \u043d\u0430\u0439\u0442\u0438 \u043a\u043e\u043c\u043f\u0440\u043e\u043c\u0438\u0441\u0441 \u043c\u0435\u0436\u0434\u0443 \u0441\u043a\u043e\u0440\u043e\u0441\u0442\u044c\u044e \u0438 \u043d\u0430\u0434\u0435\u0436\u043d\u043e\u0441\u0442\u044c\u044e. <\/p>\n\n
\u0415\u0441\u043b\u0438 \u0432\u044b \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442\u0435 \u0441 \u0440\u0430\u0441\u043f\u0440\u0435\u0434\u0435\u043b\u0451\u043d\u043d\u044b\u043c\u0438 \u0441\u0438\u0441\u0442\u0435\u043c\u0430\u043c\u0438 \u0438\u043b\u0438 \u043f\u043b\u0430\u043d\u0438\u0440\u0443\u0435\u0442\u0435 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u044c Kafka \u0432 \u043f\u0440\u043e\u0435\u043a\u0442\u0430\u0445, \u043f\u0440\u0438\u0433\u043b\u0430\u0448\u0430\u0435\u043c \u0432\u0430\u0441 \u043d\u0430 \u0441\u0435\u0440\u0438\u044e \u043e\u0442\u043a\u0440\u044b\u0442\u044b\u0445 \u0443\u0440\u043e\u043a\u043e\u0432 \u043f\u043e \u043a\u0443\u0440\u0441\u0443 Apache Kafka<\/em>:<\/p>\n