{"id":100769,"date":"2025-03-09T13:47:41","date_gmt":"2025-03-09T10:17:41","guid":{"rendered":"https:\/\/nabfollower.com\/blog\/building-a-robust-message-queue-system-with-kafka-and-goframe-4a5n\/"},"modified":"2025-03-09T13:47:41","modified_gmt":"2025-03-09T10:17:41","slug":"building-a-robust-message-queue-system-with-kafka-and-goframe-4a5n","status":"publish","type":"post","link":"https:\/\/nabfollower.com\/blog\/building-a-robust-message-queue-system-with-kafka-and-goframe-4a5n\/","title":{"rendered":"\u0633\u0627\u062e\u062a\u0646 \u06cc\u06a9 \u0633\u06cc\u0633\u062a\u0645 \u0635\u0641 \u067e\u06cc\u0627\u0645 \u0642\u0648\u06cc \u0628\u0627 \u06a9\u0627\u0641\u06a9\u0627 \u0648 \u06af\u0648\u0641\u0627\u0645"},"content":{"rendered":"<div data-article-id=\"2174022\" id=\"article-body\">\n<p>\u0633\u0644\u0627\u0645 Devs \u0647\u0645\u06a9\u0627\u0631! \ud83d\udc4b \u0627\u0645\u0631\u0648\u0632 \u060c \u0645\u0627 \u062f\u0631 \u062d\u0627\u0644 \u062a\u0628\u062f\u06cc\u0644 \u0634\u062f\u0646 \u0628\u0647 \u0646\u062d\u0648\u0647 \u0633\u0627\u062e\u062a \u06cc\u06a9 \u0633\u06cc\u0633\u062a\u0645 \u0635\u0641 \u067e\u06cc\u0627\u0645 \u0642\u0648\u06cc \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 Apache Kafka \u0628\u0627 \u0686\u0627\u0631\u0686\u0648\u0628 Goframe \u0647\u0633\u062a\u06cc\u0645. \u0627\u06cc\u0646 \u06a9\u0647 \u0622\u06cc\u0627 \u0634\u0645\u0627 \u062f\u0631 \u062d\u0627\u0644 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 \u062c\u0631\u06cc\u0627\u0646 \u062f\u0627\u062f\u0647 \u0647\u0627\u06cc \u0628\u0627 \u062a\u0648\u0627\u0646 \u0628\u0627\u0644\u0627 \u060c \u0633\u0627\u062e\u062a\u0645\u0627\u0646 \u0645\u0639\u0645\u0627\u0631\u06cc \u0647\u0627\u06cc \u0645\u062d\u0648\u0631 \u0631\u0648\u06cc\u062f\u0627\u062f \u0647\u0633\u062a\u06cc\u062f \u060c \u06cc\u0627 \u0641\u0642\u0637 \u0645\u06cc \u062e\u0648\u0627\u0647\u06cc\u062f \u062e\u062f\u0645\u0627\u062a \u062e\u0648\u062f \u0631\u0627 \u062c\u062f\u0627 \u06a9\u0646\u06cc\u062f \u060c \u0627\u06cc\u0646 \u0631\u0627\u0647\u0646\u0645\u0627 \u0634\u0645\u0627 \u0631\u0627 \u062a\u062d\u062a \u067e\u0648\u0634\u0634 \u0642\u0631\u0627\u0631 \u062f\u0627\u062f\u0647 \u0627\u0633\u062a!<\/p>\n<div id=\"ez-toc-container\" class=\"ez-toc-v2_0_84 counter-hierarchy ez-toc-counter-rtl ez-toc-grey ez-toc-container-direction\">\n<div class=\"ez-toc-title-container\">\n<p class=\"ez-toc-title\" style=\"cursor:inherit\">\u0641\u0647\u0631\u0633\u062a \u0645\u0637\u0627\u0644\u0628<\/p>\n<span class=\"ez-toc-title-toggle\"><a href=\"#\" class=\"ez-toc-pull-right ez-toc-btn ez-toc-btn-xs ez-toc-btn-default ez-toc-toggle\" aria-label=\"Toggle Table of Content\"><span class=\"ez-toc-js-icon-con\"><span class=\"\"><span class=\"eztoc-hide\" style=\"display:none;\">Toggle<\/span><span class=\"ez-toc-icon-toggle-span\"><svg style=\"fill: #999;color:#999\" xmlns=\"http:\/\/www.w3.org\/2000\/svg\" class=\"list-377408\" width=\"20px\" height=\"20px\" viewBox=\"0 0 24 24\" fill=\"none\"><path d=\"M6 6H4v2h2V6zm14 0H8v2h12V6zM4 11h2v2H4v-2zm16 0H8v2h12v-2zM4 16h2v2H4v-2zm16 0H8v2h12v-2z\" fill=\"currentColor\"><\/path><\/svg><svg style=\"fill: #999;color:#999\" class=\"arrow-unsorted-368013\" xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"10px\" height=\"10px\" viewBox=\"0 0 24 24\" version=\"1.2\" baseProfile=\"tiny\"><path d=\"M18.2 9.3l-6.2-6.3-6.2 6.3c-.2.2-.3.4-.3.7s.1.5.3.7c.2.2.4.3.7.3h11c.3 0 .5-.1.7-.3.2-.2.3-.5.3-.7s-.1-.5-.3-.7zM5.8 14.7l6.2 6.3 6.2-6.3c.2-.2.3-.5.3-.7s-.1-.5-.3-.7c-.2-.2-.4-.3-.7-.3h-11c-.3 0-.5.1-.7.3-.2.2-.3.5-.3.7s.1.5.3.7z\"\/><\/svg><\/span><\/span><\/span><\/a><\/span><\/div>\n<nav><ul class='ez-toc-list ez-toc-list-level-1 ' ><li class='ez-toc-page-1 ez-toc-heading-level-2'><a class=\"ez-toc-link ez-toc-heading-1\" href=\"https:\/\/nabfollower.com\/blog\/building-a-robust-message-queue-system-with-kafka-and-goframe-4a5n\/#%D8%A2%D9%86%DA%86%D9%87_%D8%AE%D9%88%D8%A7%D9%87%DB%8C%D9%85_%D8%B3%D8%A7%D8%AE%D8%AA\" >\u0622\u0646\u0686\u0647 \u062e\u0648\u0627\u0647\u06cc\u0645 \u0633\u0627\u062e\u062a<\/a><\/li><li class='ez-toc-page-1 ez-toc-heading-level-2'><a class=\"ez-toc-link ez-toc-heading-2\" href=\"https:\/\/nabfollower.com\/blog\/building-a-robust-message-queue-system-with-kafka-and-goframe-4a5n\/#%D9%BE%DB%8C%D8%B4_%D9%86%DB%8C%D8%A7%D8%B2%D9%87%D8%A7\" >\u067e\u06cc\u0634 \u0646\u06cc\u0627\u0632\u0647\u0627<\/a><\/li><li class='ez-toc-page-1 ez-toc-heading-level-2'><a class=\"ez-toc-link ez-toc-heading-3\" href=\"https:\/\/nabfollower.com\/blog\/building-a-robust-message-queue-system-with-kafka-and-goframe-4a5n\/#%DA%A9%D8%A7%D9%81%DA%A9%D8%A7_%D8%B3%D8%B1%DB%8C%D8%B9_%D8%A2%D8%BA%D8%A7%D8%B2%DA%AF%D8%B1\" >\u06a9\u0627\u0641\u06a9\u0627 \u0633\u0631\u06cc\u0639 \u0622\u063a\u0627\u0632\u06af\u0631<\/a><\/li><li class='ez-toc-page-1 ez-toc-heading-level-2'><a class=\"ez-toc-link ez-toc-heading-4\" href=\"https:\/\/nabfollower.com\/blog\/building-a-robust-message-queue-system-with-kafka-and-goframe-4a5n\/#%D8%A8%DB%8C%D8%A7%DB%8C%DB%8C%D8%AF_%DA%A9%D8%AF_%DA%A9%D9%86%DB%8C%D9%85_%F0%9F%92%BB\" >\u0628\u06cc\u0627\u06cc\u06cc\u062f \u06a9\u062f \u06a9\u0646\u06cc\u0645! \ud83d\udcbb<\/a><ul class='ez-toc-list-level-3' ><li class='ez-toc-heading-level-3'><a class=\"ez-toc-link ez-toc-heading-5\" href=\"https:\/\/nabfollower.com\/blog\/building-a-robust-message-queue-system-with-kafka-and-goframe-4a5n\/#1_%D8%A7%D8%A8%D8%AA%D8%AF%D8%A7_%D9%85%D8%B4%D8%AA%D8%B1%DB%8C_Kafka_%D8%B1%D8%A7_%D9%86%D8%B5%D8%A8_%DA%A9%D9%86%DB%8C%D8%AF\" >1. \u0627\u0628\u062a\u062f\u0627 \u0645\u0634\u062a\u0631\u06cc Kafka \u0631\u0627 \u0646\u0635\u0628 \u06a9\u0646\u06cc\u062f<\/a><\/li><li class='ez-toc-page-1 ez-toc-heading-level-3'><a class=\"ez-toc-link ez-toc-heading-6\" href=\"https:\/\/nabfollower.com\/blog\/building-a-robust-message-queue-system-with-kafka-and-goframe-4a5n\/#2_%D9%BE%DB%8C%DA%A9%D8%B1%D8%A8%D9%86%D8%AF%DB%8C_%D8%AE%D9%88%D8%AF_%D8%B1%D8%A7_%D8%AA%D9%86%D8%B8%DB%8C%D9%85_%DA%A9%D9%86%DB%8C%D8%AF\" >2. \u067e\u06cc\u06a9\u0631\u0628\u0646\u062f\u06cc \u062e\u0648\u062f \u0631\u0627 \u062a\u0646\u0638\u06cc\u0645 \u06a9\u0646\u06cc\u062f<\/a><\/li><li class='ez-toc-page-1 ez-toc-heading-level-3'><a class=\"ez-toc-link ez-toc-heading-7\" href=\"https:\/\/nabfollower.com\/blog\/building-a-robust-message-queue-system-with-kafka-and-goframe-4a5n\/#3_%D8%AA%D9%88%D9%84%DB%8C%D8%AF_%DA%A9%D9%86%D9%86%D8%AF%D9%87_%D8%AE%D9%88%D8%AF_%D8%B1%D8%A7_%D8%A7%DB%8C%D8%AC%D8%A7%D8%AF_%DA%A9%D9%86%DB%8C%D8%AF\" >3. \u062a\u0648\u0644\u06cc\u062f \u06a9\u0646\u0646\u062f\u0647 \u062e\u0648\u062f \u0631\u0627 \u0627\u06cc\u062c\u0627\u062f \u06a9\u0646\u06cc\u062f<\/a><\/li><li class='ez-toc-page-1 ez-toc-heading-level-3'><a class=\"ez-toc-link ez-toc-heading-8\" href=\"https:\/\/nabfollower.com\/blog\/building-a-robust-message-queue-system-with-kafka-and-goframe-4a5n\/#4_%D9%85%D8%B5%D8%B1%D9%81_%DA%A9%D9%86%D9%86%D8%AF%D9%87_%D8%AE%D9%88%D8%AF_%D8%B1%D8%A7_%D8%AA%D9%86%D8%B8%DB%8C%D9%85_%DA%A9%D9%86%DB%8C%D8%AF\" >4. \u0645\u0635\u0631\u0641 \u06a9\u0646\u0646\u062f\u0647 \u062e\u0648\u062f \u0631\u0627 \u062a\u0646\u0638\u06cc\u0645 \u06a9\u0646\u06cc\u062f<\/a><\/li><\/ul><\/li><li class='ez-toc-page-1 ez-toc-heading-level-2'><a class=\"ez-toc-link ez-toc-heading-9\" href=\"https:\/\/nabfollower.com\/blog\/building-a-robust-message-queue-system-with-kafka-and-goframe-4a5n\/#%D8%B3%D8%A7%D8%AE%D8%AA_%D8%A2%D9%86_%D8%A2%D9%85%D8%A7%D8%AF%D9%87_%D8%AA%D9%88%D9%84%DB%8C%D8%AF\" >\u0633\u0627\u062e\u062a \u0622\u0646 \u0622\u0645\u0627\u062f\u0647 \u062a\u0648\u0644\u06cc\u062f<\/a><ul class='ez-toc-list-level-3' ><li class='ez-toc-heading-level-3'><a class=\"ez-toc-link ez-toc-heading-10\" href=\"https:\/\/nabfollower.com\/blog\/building-a-robust-message-queue-system-with-kafka-and-goframe-4a5n\/#%D8%A7%D8%B1%D8%B3%D8%A7%D9%84_%D9%BE%DB%8C%D8%A7%D9%85_%D8%A8%D8%A7_%D8%B1%D8%B3%DB%8C%D8%AF%DA%AF%DB%8C_%D8%A8%D9%87_%D8%AE%D8%B7%D8%A7\" >\u0627\u0631\u0633\u0627\u0644 \u067e\u06cc\u0627\u0645 \u0628\u0627 \u0631\u0633\u06cc\u062f\u06af\u06cc \u0628\u0647 \u062e\u0637\u0627<\/a><\/li><li class='ez-toc-page-1 ez-toc-heading-level-3'><a class=\"ez-toc-link ez-toc-heading-11\" href=\"https:\/\/nabfollower.com\/blog\/building-a-robust-message-queue-system-with-kafka-and-goframe-4a5n\/#%D9%85%D8%B5%D8%B1%D9%81_%D9%BE%DB%8C%D8%A7%D9%85_%D9%87%D8%A7%DB%8C%DB%8C_%D9%85%D8%A7%D9%86%D9%86%D8%AF_%DB%8C%DA%A9_%D8%AD%D8%B1%D9%81%D9%87_%D8%A7%DB%8C\" >\u0645\u0635\u0631\u0641 \u067e\u06cc\u0627\u0645 \u0647\u0627\u06cc\u06cc \u0645\u0627\u0646\u0646\u062f \u06cc\u06a9 \u062d\u0631\u0641\u0647 \u0627\u06cc<\/a><\/li><li class='ez-toc-page-1 ez-toc-heading-level-3'><a class=\"ez-toc-link ez-toc-heading-12\" href=\"https:\/\/nabfollower.com\/blog\/building-a-robust-message-queue-system-with-kafka-and-goframe-4a5n\/#%D8%A7%D9%81%D8%B2%D9%88%D8%AF%D9%86_%D9%85%D9%86%D8%B7%D9%82_%D8%A2%D8%B2%D9%85%D8%A7%DB%8C%D8%B4_%D9%85%D8%AC%D8%AF%D8%AF\" >\u0627\u0641\u0632\u0648\u062f\u0646 \u0645\u0646\u0637\u0642 \u0622\u0632\u0645\u0627\u06cc\u0634 \u0645\u062c\u062f\u062f<\/a><\/li><\/ul><\/li><li class='ez-toc-page-1 ez-toc-heading-level-2'><a class=\"ez-toc-link ez-toc-heading-13\" href=\"https:\/\/nabfollower.com\/blog\/building-a-robust-message-queue-system-with-kafka-and-goframe-4a5n\/#%D9%86%DA%A9%D8%A7%D8%AA_%D8%AD%D8%B1%D9%81%D9%87_%D8%A7%DB%8C\" >\u0646\u06a9\u0627\u062a \u062d\u0631\u0641\u0647 \u0627\u06cc<\/a><\/li><li class='ez-toc-page-1 ez-toc-heading-level-2'><a class=\"ez-toc-link ez-toc-heading-14\" href=\"https:\/\/nabfollower.com\/blog\/building-a-robust-message-queue-system-with-kafka-and-goframe-4a5n\/#%DA%86%D9%87_%DA%86%DB%8C%D8%B2%DB%8C_%D8%A8%D8%B9%D8%AF%DB%8C%D8%9F_%F0%9F%9A%80\" >\u0686\u0647 \u0686\u06cc\u0632\u06cc \u0628\u0639\u062f\u06cc\u061f \ud83d\ude80<\/a><\/li><li class='ez-toc-page-1 ez-toc-heading-level-2'><a class=\"ez-toc-link ez-toc-heading-15\" href=\"https:\/\/nabfollower.com\/blog\/building-a-robust-message-queue-system-with-kafka-and-goframe-4a5n\/#%D8%A8%D8%B3%D8%AA%D9%87_%D8%A8%D9%86%D8%AF%DB%8C\" >\u0628\u0633\u062a\u0647 \u0628\u0646\u062f\u06cc<\/a><\/li><\/ul><\/nav><\/div>\n<h2><span class=\"ez-toc-section\" id=\"%D8%A2%D9%86%DA%86%D9%87_%D8%AE%D9%88%D8%A7%D9%87%DB%8C%D9%85_%D8%B3%D8%A7%D8%AE%D8%AA\"><\/span>\n<p>  \u0622\u0646\u0686\u0647 \u062e\u0648\u0627\u0647\u06cc\u0645 \u0633\u0627\u062e\u062a<br \/>\n<span class=\"ez-toc-section-end\"><\/span><\/h2>\n<p>\u0645\u0627 \u06cc\u06a9 \u0633\u06cc\u0633\u062a\u0645 \u0635\u0641 \u067e\u06cc\u0627\u0645 \u06a9\u0627\u0645\u0644 \u0627\u06cc\u062c\u0627\u062f \u062e\u0648\u0627\u0647\u06cc\u0645 \u06a9\u0631\u062f \u06a9\u0647 \u0645\u06cc \u062a\u0648\u0627\u0646\u062f:<\/p>\n<ul>\n<li>\u062a\u0648\u0644\u06cc\u062f \u06a9\u0646\u0646\u062f\u06af\u0627\u0646 \u0648 \u0645\u0635\u0631\u0641 \u06a9\u0646\u0646\u062f\u06af\u0627\u0646 \u06a9\u0627\u0641\u06a9\u0627 \u0631\u0627 \u062f\u0631 Goframe \u0631\u0627\u0647 \u0627\u0646\u062f\u0627\u0632\u06cc \u06a9\u0646\u06cc\u062f<\/li>\n<li>\u0627\u0646\u062a\u0634\u0627\u0631 \u067e\u06cc\u0627\u0645 \u0648 \u0645\u0635\u0631\u0641 \u067e\u06cc\u0627\u0645<\/li>\n<li>\u0627\u062c\u0631\u0627\u06cc \u062e\u0637\u0627\u06cc \u0642\u0648\u06cc<\/li>\n<li>\u0645\u06a9\u0627\u0646\u06cc\u0633\u0645 \u0647\u0627\u06cc \u0622\u0632\u0645\u0627\u06cc\u0634 \u0645\u062c\u062f\u062f \u0631\u0627 \u0628\u0631\u0627\u06cc \u0639\u0645\u0644\u06cc\u0627\u062a \u0646\u0627\u0645\u0648\u0641\u0642 \u0627\u0636\u0627\u0641\u0647 \u06a9\u0646\u06cc\u062f<\/li>\n<\/ul>\n<h2><span class=\"ez-toc-section\" id=\"%D9%BE%DB%8C%D8%B4_%D9%86%DB%8C%D8%A7%D8%B2%D9%87%D8%A7\"><\/span>\n<p>  \u067e\u06cc\u0634 \u0646\u06cc\u0627\u0632\u0647\u0627<br \/>\n<span class=\"ez-toc-section-end\"><\/span><\/h2>\n<p>\u0642\u0628\u0644 \u0627\u0632 \u0634\u0631\u0648\u0639 \u060c \u0627\u0637\u0645\u06cc\u0646\u0627\u0646 \u062d\u0627\u0635\u0644 \u06a9\u0646\u06cc\u062f \u06a9\u0647:<\/p>\n<ul>\n<li>\u0631\u0648\u06cc \u062f\u0633\u062a\u06af\u0627\u0647 \u062e\u0648\u062f \u0646\u0635\u0628 \u06a9\u0646\u06cc\u062f<\/li>\n<li>\u062f\u0631\u06a9 \u0627\u0633\u0627\u0633\u06cc \u0627\u0632 \u0635\u0641 \u0647\u0627\u06cc GO \u0648 \u067e\u06cc\u0627\u0645<\/li>\n<li>Kafka \u0648 Zookeeper \u06a9\u0647 \u0628\u0647 \u0635\u0648\u0631\u062a \u0645\u062d\u0644\u06cc \u062f\u0631 \u062d\u0627\u0644 \u0627\u062c\u0631\u0627 \u0647\u0633\u062a\u0646\u062f \u06cc\u0627 \u06cc\u06a9 \u062e\u0648\u0634\u0647 Kafka \u06a9\u0647 \u0645\u06cc \u062a\u0648\u0627\u0646\u06cc\u062f \u0628\u0647 \u0622\u0646 \u0648\u0635\u0644 \u0634\u0648\u06cc\u062f<\/li>\n<li>\u0686\u0627\u0631\u0686\u0648\u0628 Goframe \u0646\u0635\u0628 \u0634\u062f\u0647<\/li>\n<\/ul>\n<h2><span class=\"ez-toc-section\" id=\"%DA%A9%D8%A7%D9%81%DA%A9%D8%A7_%D8%B3%D8%B1%DB%8C%D8%B9_%D8%A2%D8%BA%D8%A7%D8%B2%DA%AF%D8%B1\"><\/span>\n<p>  \u06a9\u0627\u0641\u06a9\u0627 \u0633\u0631\u06cc\u0639 \u0622\u063a\u0627\u0632\u06af\u0631<br \/>\n<span class=\"ez-toc-section-end\"><\/span><\/h2>\n<p>\u0627\u06af\u0631 \u062a\u0627\u0632\u0647 \u0648\u0627\u0631\u062f \u06a9\u0627\u0641\u06a9\u0627 \u0647\u0633\u062a\u06cc\u062f \u060c \u0622\u0646\u0686\u0647 \u0631\u0627 \u06a9\u0647 \u0628\u0627\u06cc\u062f \u0628\u062f\u0627\u0646\u06cc\u062f \u062f\u0631 \u0627\u06cc\u0646\u062c\u0627 \u0622\u0648\u0631\u062f\u0647 \u0634\u062f\u0647 \u0627\u0633\u062a. Kafka \u06cc\u06a9 \u0633\u06cc\u0633\u062a\u0645 \u067e\u06cc\u0627\u0645 \u0631\u0633\u0627\u0646\u06cc \u062a\u0648\u0632\u06cc\u0639 \u0634\u062f\u0647 \u0627\u0633\u062a \u06a9\u0647 \u062f\u0631 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 \u062c\u0631\u06cc\u0627\u0646 \u062f\u0627\u062f\u0647 \u0647\u0627\u06cc \u0628\u0627 \u062a\u0648\u0627\u0646 \u0628\u0627\u0644\u0627 \u0628\u0631\u062a\u0631\u06cc \u062f\u0627\u0631\u062f. \u0645\u0641\u0627\u0647\u06cc\u0645 \u06a9\u0644\u06cc\u062f\u06cc \u0639\u0628\u0627\u0631\u062a\u0646\u062f \u0627\u0632:<\/p>\n<ul>\n<li>\n<strong>\u062a\u0648\u0644\u06cc\u062f \u06a9\u0646\u0646\u062f\u0647<\/strong>: \u0641\u0631\u0633\u062a\u0646\u062f\u0647 \u067e\u06cc\u0627\u0645 \u0634\u0645\u0627<\/li>\n<li>\n<strong>\u0645\u0635\u0631\u0641 \u06a9\u0646\u0646\u062f\u0647<\/strong>: \u06af\u06cc\u0631\u0646\u062f\u0647 \u067e\u06cc\u0627\u0645 \u0634\u0645\u0627<\/li>\n<li>\n<strong>\u06a9\u0627\u0631\u06af\u0632\u0627\u0631<\/strong>: \u0633\u0631\u0648\u0631 \u06a9\u0627\u0641\u06a9\u0627<\/li>\n<li>\n<strong>\u0645\u0648\u0636\u0648\u0639<\/strong>: \u062f\u0633\u062a\u0647 \u0628\u0646\u062f\u06cc \u0628\u0631\u0627\u06cc \u067e\u06cc\u0627\u0645 \u0647\u0627\u06cc \u0634\u0645\u0627<\/li>\n<li>\n<strong>\u067e\u0627\u0631\u062a\u06cc\u0634\u0646<\/strong>: \u0686\u06af\u0648\u0646\u0647 \u0645\u0628\u0627\u062d\u062b \u0628\u0631\u0627\u06cc \u0645\u0642\u06cc\u0627\u0633 \u067e\u0630\u06cc\u0631\u06cc \u062a\u0642\u0633\u06cc\u0645 \u0645\u06cc \u0634\u0648\u0646\u062f<\/li>\n<\/ul>\n<h2><span class=\"ez-toc-section\" id=\"%D8%A8%DB%8C%D8%A7%DB%8C%DB%8C%D8%AF_%DA%A9%D8%AF_%DA%A9%D9%86%DB%8C%D9%85_%F0%9F%92%BB\"><\/span>\n<p>  \u0628\u06cc\u0627\u06cc\u06cc\u062f \u06a9\u062f \u06a9\u0646\u06cc\u0645! \ud83d\udcbb<br \/>\n<span class=\"ez-toc-section-end\"><\/span><\/h2>\n<h3><span class=\"ez-toc-section\" id=\"1_%D8%A7%D8%A8%D8%AA%D8%AF%D8%A7_%D9%85%D8%B4%D8%AA%D8%B1%DB%8C_Kafka_%D8%B1%D8%A7_%D9%86%D8%B5%D8%A8_%DA%A9%D9%86%DB%8C%D8%AF\"><\/span>\n<p>  1. \u0627\u0628\u062a\u062f\u0627 \u0645\u0634\u062a\u0631\u06cc Kafka \u0631\u0627 \u0646\u0635\u0628 \u06a9\u0646\u06cc\u062f<br \/>\n<span class=\"ez-toc-section-end\"><\/span><\/h3>\n<div class=\"highlight js-code-highlight\">\n<pre class=\"highlight shell\"><code>go get github.com\/IBM\/sarama\n<\/code><\/pre>\n<div class=\"highlight__panel js-actions-panel\">\n<div class=\"highlight__panel-action js-fullscreen-code-action\">\n    <svg xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"20px\" height=\"20px\" viewbox=\"0 0 24 24\" class=\"highlight-action crayons-icon highlight-action--fullscreen-on\"><title>\u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u0631\u0627 \u0648\u0627\u0631\u062f \u06a9\u0646\u06cc\u062f<\/title>\n    <path d=\"M16 3h6v6h-2V5h-4V3zM2 3h6v2H4v4H2V3zm18 16v-4h2v6h-6v-2h4zM4 19h4v2H2v-6h2v4z\"\/>\n<\/svg><\/p>\n<p>    <svg xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"20px\" height=\"20px\" viewbox=\"0 0 24 24\" class=\"highlight-action crayons-icon highlight-action--fullscreen-off\"><title>\u0627\u0632 \u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u062e\u0627\u0631\u062c \u0634\u0648\u06cc\u062f<\/title>\n    <path d=\"M18 7h4v2h-6V3h2v4zM8 9H2V7h4V3h2v6zm10 8v4h-2v-6h6v2h-4zM8 15v6H6v-4H2v-2h6z\"\/>\n<\/svg><\/p>\n<\/div>\n<\/div>\n<\/div>\n<h3><span class=\"ez-toc-section\" id=\"2_%D9%BE%DB%8C%DA%A9%D8%B1%D8%A8%D9%86%D8%AF%DB%8C_%D8%AE%D9%88%D8%AF_%D8%B1%D8%A7_%D8%AA%D9%86%D8%B8%DB%8C%D9%85_%DA%A9%D9%86%DB%8C%D8%AF\"><\/span>\n<p>  2. \u067e\u06cc\u06a9\u0631\u0628\u0646\u062f\u06cc \u062e\u0648\u062f \u0631\u0627 \u062a\u0646\u0638\u06cc\u0645 \u06a9\u0646\u06cc\u062f<br \/>\n<span class=\"ez-toc-section-end\"><\/span><\/h3>\n<p>\u06cc\u06a9 \u0641\u0627\u06cc\u0644 \u067e\u06cc\u06a9\u0631\u0628\u0646\u062f\u06cc \u0627\u06cc\u062c\u0627\u062f \u06a9\u0646\u06cc\u062f \u06a9\u0647 Kafka \u0627\u0632 \u0622\u0646 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u062e\u0648\u0627\u0647\u062f \u06a9\u0631\u062f:<\/p>\n<div class=\"highlight js-code-highlight\">\n<pre class=\"highlight yaml\"><code><span class=\"c1\"># config.yaml<\/span>\n<span class=\"na\">kafka<\/span><span class=\"pi\">:<\/span>\n  <span class=\"na\">address<\/span><span class=\"pi\">:<\/span> \n    <span class=\"pi\">-<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">localhost:9092\"<\/span>\n  <span class=\"na\">topic<\/span><span class=\"pi\">:<\/span> <span class=\"s2\">\"<\/span><span class=\"s\">my_topic\"<\/span>\n<\/code><\/pre>\n<div class=\"highlight__panel js-actions-panel\">\n<div class=\"highlight__panel-action js-fullscreen-code-action\">\n    <svg xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"20px\" height=\"20px\" viewbox=\"0 0 24 24\" class=\"highlight-action crayons-icon highlight-action--fullscreen-on\"><title>\u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u0631\u0627 \u0648\u0627\u0631\u062f \u06a9\u0646\u06cc\u062f<\/title>\n    <path d=\"M16 3h6v6h-2V5h-4V3zM2 3h6v2H4v4H2V3zm18 16v-4h2v6h-6v-2h4zM4 19h4v2H2v-6h2v4z\"\/>\n<\/svg><\/p>\n<p>    <svg xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"20px\" height=\"20px\" viewbox=\"0 0 24 24\" class=\"highlight-action crayons-icon highlight-action--fullscreen-off\"><title>\u0627\u0632 \u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u062e\u0627\u0631\u062c \u0634\u0648\u06cc\u062f<\/title>\n    <path d=\"M18 7h4v2h-6V3h2v4zM8 9H2V7h4V3h2v6zm10 8v4h-2v-6h6v2h-4zM8 15v6H6v-4H2v-2h6z\"\/>\n<\/svg><\/p>\n<\/div>\n<\/div>\n<\/div>\n<h3><span class=\"ez-toc-section\" id=\"3_%D8%AA%D9%88%D9%84%DB%8C%D8%AF_%DA%A9%D9%86%D9%86%D8%AF%D9%87_%D8%AE%D9%88%D8%AF_%D8%B1%D8%A7_%D8%A7%DB%8C%D8%AC%D8%A7%D8%AF_%DA%A9%D9%86%DB%8C%D8%AF\"><\/span>\n<p>  3. \u062a\u0648\u0644\u06cc\u062f \u06a9\u0646\u0646\u062f\u0647 \u062e\u0648\u062f \u0631\u0627 \u0627\u06cc\u062c\u0627\u062f \u06a9\u0646\u06cc\u062f<br \/>\n<span class=\"ez-toc-section-end\"><\/span><\/h3>\n<div class=\"highlight js-code-highlight\">\n<pre class=\"highlight go\"><code><span class=\"k\">package<\/span> <span class=\"n\">main<\/span>\n\n<span class=\"k\">import<\/span> <span class=\"p\">(<\/span>\n    <span class=\"s\">\"context\"<\/span>\n    <span class=\"s\">\"github.com\/gogf\/gf\/v2\/frame\/g\"<\/span>\n    <span class=\"s\">\"github.com\/gogf\/gf\/v2\/os\/gctx\"<\/span>\n    <span class=\"s\">\"github.com\/IBM\/sarama\"<\/span>\n<span class=\"p\">)<\/span>\n\n<span class=\"k\">var<\/span> <span class=\"n\">kafkaProducer<\/span> <span class=\"n\">sarama<\/span><span class=\"o\">.<\/span><span class=\"n\">SyncProducer<\/span>\n\n<span class=\"k\">func<\/span> <span class=\"n\">initKafkaProducer<\/span><span class=\"p\">(<\/span><span class=\"n\">ctx<\/span> <span class=\"n\">context<\/span><span class=\"o\">.<\/span><span class=\"n\">Context<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>\n    <span class=\"c\">\/\/ Create producer config<\/span>\n    <span class=\"n\">config<\/span> <span class=\"o\">:=<\/span> <span class=\"n\">sarama<\/span><span class=\"o\">.<\/span><span class=\"n\">NewConfig<\/span><span class=\"p\">()<\/span>\n    <span class=\"n\">config<\/span><span class=\"o\">.<\/span><span class=\"n\">Producer<\/span><span class=\"o\">.<\/span><span class=\"n\">Return<\/span><span class=\"o\">.<\/span><span class=\"n\">Successes<\/span> <span class=\"o\">=<\/span> <span class=\"no\">true<\/span>\n\n    <span class=\"c\">\/\/ Get address from config<\/span>\n    <span class=\"n\">address<\/span> <span class=\"o\">:=<\/span> <span class=\"n\">g<\/span><span class=\"o\">.<\/span><span class=\"n\">Cfg<\/span><span class=\"p\">()<\/span><span class=\"o\">.<\/span><span class=\"n\">MustGet<\/span><span class=\"p\">(<\/span><span class=\"n\">ctx<\/span><span class=\"p\">,<\/span> <span class=\"s\">\"kafka.address\"<\/span><span class=\"p\">)<\/span><span class=\"o\">.<\/span><span class=\"n\">Strings<\/span><span class=\"p\">()<\/span>\n\n    <span class=\"c\">\/\/ Initialize producer<\/span>\n    <span class=\"n\">producer<\/span><span class=\"p\">,<\/span> <span class=\"n\">err<\/span> <span class=\"o\">:=<\/span> <span class=\"n\">sarama<\/span><span class=\"o\">.<\/span><span class=\"n\">NewSyncProducer<\/span><span class=\"p\">(<\/span><span class=\"n\">address<\/span><span class=\"p\">,<\/span> <span class=\"n\">config<\/span><span class=\"p\">)<\/span>\n    <span class=\"k\">if<\/span> <span class=\"n\">err<\/span> <span class=\"o\">!=<\/span> <span class=\"no\">nil<\/span> <span class=\"p\">{<\/span>\n       <span class=\"nb\">panic<\/span><span class=\"p\">(<\/span><span class=\"n\">err<\/span><span class=\"p\">)<\/span>\n    <span class=\"p\">}<\/span>\n    <span class=\"n\">kafkaProducer<\/span> <span class=\"o\">=<\/span> <span class=\"n\">producer<\/span>\n<span class=\"p\">}<\/span>\n<\/code><\/pre>\n<div class=\"highlight__panel js-actions-panel\">\n<div class=\"highlight__panel-action js-fullscreen-code-action\">\n    <svg xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"20px\" height=\"20px\" viewbox=\"0 0 24 24\" class=\"highlight-action crayons-icon highlight-action--fullscreen-on\"><title>\u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u0631\u0627 \u0648\u0627\u0631\u062f \u06a9\u0646\u06cc\u062f<\/title>\n    <path d=\"M16 3h6v6h-2V5h-4V3zM2 3h6v2H4v4H2V3zm18 16v-4h2v6h-6v-2h4zM4 19h4v2H2v-6h2v4z\"\/>\n<\/svg><\/p>\n<p>    <svg xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"20px\" height=\"20px\" viewbox=\"0 0 24 24\" class=\"highlight-action crayons-icon highlight-action--fullscreen-off\"><title>\u0627\u0632 \u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u062e\u0627\u0631\u062c \u0634\u0648\u06cc\u062f<\/title>\n    <path d=\"M18 7h4v2h-6V3h2v4zM8 9H2V7h4V3h2v6zm10 8v4h-2v-6h6v2h-4zM8 15v6H6v-4H2v-2h6z\"\/>\n<\/svg><\/p>\n<\/div>\n<\/div>\n<\/div>\n<h3><span class=\"ez-toc-section\" id=\"4_%D9%85%D8%B5%D8%B1%D9%81_%DA%A9%D9%86%D9%86%D8%AF%D9%87_%D8%AE%D9%88%D8%AF_%D8%B1%D8%A7_%D8%AA%D9%86%D8%B8%DB%8C%D9%85_%DA%A9%D9%86%DB%8C%D8%AF\"><\/span>\n<p>  4. \u0645\u0635\u0631\u0641 \u06a9\u0646\u0646\u062f\u0647 \u062e\u0648\u062f \u0631\u0627 \u062a\u0646\u0638\u06cc\u0645 \u06a9\u0646\u06cc\u062f<br \/>\n<span class=\"ez-toc-section-end\"><\/span><\/h3>\n<div class=\"highlight js-code-highlight\">\n<pre class=\"highlight go\"><code><span class=\"k\">var<\/span> <span class=\"n\">kafkaConsumer<\/span> <span class=\"n\">sarama<\/span><span class=\"o\">.<\/span><span class=\"n\">Consumer<\/span>\n\n<span class=\"k\">func<\/span> <span class=\"n\">initKafkaConsumer<\/span><span class=\"p\">(<\/span><span class=\"n\">ctx<\/span> <span class=\"n\">context<\/span><span class=\"o\">.<\/span><span class=\"n\">Context<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>\n    <span class=\"n\">address<\/span> <span class=\"o\">:=<\/span> <span class=\"n\">g<\/span><span class=\"o\">.<\/span><span class=\"n\">Cfg<\/span><span class=\"p\">()<\/span><span class=\"o\">.<\/span><span class=\"n\">MustGet<\/span><span class=\"p\">(<\/span><span class=\"n\">ctx<\/span><span class=\"p\">,<\/span> <span class=\"s\">\"kafka.address\"<\/span><span class=\"p\">)<\/span><span class=\"o\">.<\/span><span class=\"n\">Strings<\/span><span class=\"p\">()<\/span>\n\n    <span class=\"n\">consumer<\/span><span class=\"p\">,<\/span> <span class=\"n\">err<\/span> <span class=\"o\">:=<\/span> <span class=\"n\">sarama<\/span><span class=\"o\">.<\/span><span class=\"n\">NewConsumer<\/span><span class=\"p\">(<\/span><span class=\"n\">address<\/span><span class=\"p\">,<\/span> <span class=\"no\">nil<\/span><span class=\"p\">)<\/span>\n    <span class=\"k\">if<\/span> <span class=\"n\">err<\/span> <span class=\"o\">!=<\/span> <span class=\"no\">nil<\/span> <span class=\"p\">{<\/span>\n       <span class=\"nb\">panic<\/span><span class=\"p\">(<\/span><span class=\"n\">err<\/span><span class=\"p\">)<\/span>\n    <span class=\"p\">}<\/span>\n    <span class=\"n\">kafkaConsumer<\/span> <span class=\"o\">=<\/span> <span class=\"n\">consumer<\/span>\n<span class=\"p\">}<\/span>\n<\/code><\/pre>\n<div class=\"highlight__panel js-actions-panel\">\n<div class=\"highlight__panel-action js-fullscreen-code-action\">\n    <svg xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"20px\" height=\"20px\" viewbox=\"0 0 24 24\" class=\"highlight-action crayons-icon highlight-action--fullscreen-on\"><title>\u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u0631\u0627 \u0648\u0627\u0631\u062f \u06a9\u0646\u06cc\u062f<\/title>\n    <path d=\"M16 3h6v6h-2V5h-4V3zM2 3h6v2H4v4H2V3zm18 16v-4h2v6h-6v-2h4zM4 19h4v2H2v-6h2v4z\"\/>\n<\/svg><\/p>\n<p>    <svg xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"20px\" height=\"20px\" viewbox=\"0 0 24 24\" class=\"highlight-action crayons-icon highlight-action--fullscreen-off\"><title>\u0627\u0632 \u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u062e\u0627\u0631\u062c \u0634\u0648\u06cc\u062f<\/title>\n    <path d=\"M18 7h4v2h-6V3h2v4zM8 9H2V7h4V3h2v6zm10 8v4h-2v-6h6v2h-4zM8 15v6H6v-4H2v-2h6z\"\/>\n<\/svg><\/p>\n<\/div>\n<\/div>\n<\/div>\n<h2><span class=\"ez-toc-section\" id=\"%D8%B3%D8%A7%D8%AE%D8%AA_%D8%A2%D9%86_%D8%A2%D9%85%D8%A7%D8%AF%D9%87_%D8%AA%D9%88%D9%84%DB%8C%D8%AF\"><\/span>\n<p>  \u0633\u0627\u062e\u062a \u0622\u0646 \u0622\u0645\u0627\u062f\u0647 \u062a\u0648\u0644\u06cc\u062f<br \/>\n<span class=\"ez-toc-section-end\"><\/span><\/h2>\n<h3><span class=\"ez-toc-section\" id=\"%D8%A7%D8%B1%D8%B3%D8%A7%D9%84_%D9%BE%DB%8C%D8%A7%D9%85_%D8%A8%D8%A7_%D8%B1%D8%B3%DB%8C%D8%AF%DA%AF%DB%8C_%D8%A8%D9%87_%D8%AE%D8%B7%D8%A7\"><\/span>\n<p>  \u0627\u0631\u0633\u0627\u0644 \u067e\u06cc\u0627\u0645 \u0628\u0627 \u0631\u0633\u06cc\u062f\u06af\u06cc \u0628\u0647 \u062e\u0637\u0627<br \/>\n<span class=\"ez-toc-section-end\"><\/span><\/h3>\n<div class=\"highlight js-code-highlight\">\n<pre class=\"highlight go\"><code><span class=\"k\">func<\/span> <span class=\"n\">sendMessage<\/span><span class=\"p\">(<\/span><span class=\"n\">ctx<\/span> <span class=\"n\">context<\/span><span class=\"o\">.<\/span><span class=\"n\">Context<\/span><span class=\"p\">,<\/span> <span class=\"n\">message<\/span> <span class=\"kt\">string<\/span><span class=\"p\">)<\/span> <span class=\"kt\">error<\/span> <span class=\"p\">{<\/span>\n    <span class=\"n\">msg<\/span> <span class=\"o\">:=<\/span> <span class=\"o\">&amp;<\/span><span class=\"n\">sarama<\/span><span class=\"o\">.<\/span><span class=\"n\">ProducerMessage<\/span><span class=\"p\">{<\/span>\n        <span class=\"n\">Topic<\/span><span class=\"o\">:<\/span> <span class=\"n\">g<\/span><span class=\"o\">.<\/span><span class=\"n\">Cfg<\/span><span class=\"p\">()<\/span><span class=\"o\">.<\/span><span class=\"n\">MustGet<\/span><span class=\"p\">(<\/span><span class=\"n\">ctx<\/span><span class=\"p\">,<\/span> <span class=\"s\">\"kafka.topic\"<\/span><span class=\"p\">)<\/span><span class=\"o\">.<\/span><span class=\"n\">String<\/span><span class=\"p\">(),<\/span>\n        <span class=\"n\">Value<\/span><span class=\"o\">:<\/span> <span class=\"n\">sarama<\/span><span class=\"o\">.<\/span><span class=\"n\">StringEncoder<\/span><span class=\"p\">(<\/span><span class=\"n\">message<\/span><span class=\"p\">),<\/span>\n    <span class=\"p\">}<\/span>\n\n    <span class=\"n\">partition<\/span><span class=\"p\">,<\/span> <span class=\"n\">offset<\/span><span class=\"p\">,<\/span> <span class=\"n\">err<\/span> <span class=\"o\">:=<\/span> <span class=\"n\">kafkaProducer<\/span><span class=\"o\">.<\/span><span class=\"n\">SendMessage<\/span><span class=\"p\">(<\/span><span class=\"n\">msg<\/span><span class=\"p\">)<\/span>\n    <span class=\"k\">if<\/span> <span class=\"n\">err<\/span> <span class=\"o\">!=<\/span> <span class=\"no\">nil<\/span> <span class=\"p\">{<\/span>\n        <span class=\"k\">return<\/span> <span class=\"n\">fmt<\/span><span class=\"o\">.<\/span><span class=\"n\">Errorf<\/span><span class=\"p\">(<\/span><span class=\"s\">\"failed to send message: %w\"<\/span><span class=\"p\">,<\/span> <span class=\"n\">err<\/span><span class=\"p\">)<\/span>\n    <span class=\"p\">}<\/span>\n\n    <span class=\"n\">g<\/span><span class=\"o\">.<\/span><span class=\"n\">Log<\/span><span class=\"p\">()<\/span><span class=\"o\">.<\/span><span class=\"n\">Infof<\/span><span class=\"p\">(<\/span><span class=\"n\">ctx<\/span><span class=\"p\">,<\/span> <span class=\"s\">\"Message sent successfully partition=%d, offset=%d\"<\/span><span class=\"p\">,<\/span> \n        <span class=\"n\">partition<\/span><span class=\"p\">,<\/span> <span class=\"n\">offset<\/span><span class=\"p\">)<\/span>\n    <span class=\"k\">return<\/span> <span class=\"no\">nil<\/span>\n<span class=\"p\">}<\/span>\n<\/code><\/pre>\n<div class=\"highlight__panel js-actions-panel\">\n<div class=\"highlight__panel-action js-fullscreen-code-action\">\n    <svg xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"20px\" height=\"20px\" viewbox=\"0 0 24 24\" class=\"highlight-action crayons-icon highlight-action--fullscreen-on\"><title>\u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u0631\u0627 \u0648\u0627\u0631\u062f \u06a9\u0646\u06cc\u062f<\/title>\n    <path d=\"M16 3h6v6h-2V5h-4V3zM2 3h6v2H4v4H2V3zm18 16v-4h2v6h-6v-2h4zM4 19h4v2H2v-6h2v4z\"\/>\n<\/svg><\/p>\n<p>    <svg xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"20px\" height=\"20px\" viewbox=\"0 0 24 24\" class=\"highlight-action crayons-icon highlight-action--fullscreen-off\"><title>\u0627\u0632 \u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u062e\u0627\u0631\u062c \u0634\u0648\u06cc\u062f<\/title>\n    <path d=\"M18 7h4v2h-6V3h2v4zM8 9H2V7h4V3h2v6zm10 8v4h-2v-6h6v2h-4zM8 15v6H6v-4H2v-2h6z\"\/>\n<\/svg><\/p>\n<\/div>\n<\/div>\n<\/div>\n<h3><span class=\"ez-toc-section\" id=\"%D9%85%D8%B5%D8%B1%D9%81_%D9%BE%DB%8C%D8%A7%D9%85_%D9%87%D8%A7%DB%8C%DB%8C_%D9%85%D8%A7%D9%86%D9%86%D8%AF_%DB%8C%DA%A9_%D8%AD%D8%B1%D9%81%D9%87_%D8%A7%DB%8C\"><\/span>\n<p>  \u0645\u0635\u0631\u0641 \u067e\u06cc\u0627\u0645 \u0647\u0627\u06cc\u06cc \u0645\u0627\u0646\u0646\u062f \u06cc\u06a9 \u062d\u0631\u0641\u0647 \u0627\u06cc<br \/>\n<span class=\"ez-toc-section-end\"><\/span><\/h3>\n<p>\u062f\u0631 \u0627\u06cc\u0646\u062c\u0627 \u06cc\u06a9 \u0627\u062c\u0631\u0627\u06cc \u0642\u0648\u06cc \u0645\u0635\u0631\u0641 \u06a9\u0646\u0646\u062f\u0647 \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 \u062e\u0637\u0627 \u0648 \u062e\u0627\u0645\u0648\u0634 \u06a9\u0631\u062f\u0646 \u0628\u0631\u0627\u0632\u0646\u062f\u0647 \u0648\u062c\u0648\u062f \u062f\u0627\u0631\u062f:<\/p>\n<div class=\"highlight js-code-highlight\">\n<pre class=\"highlight go\"><code><span class=\"k\">func<\/span> <span class=\"n\">consumeMessages<\/span><span class=\"p\">(<\/span><span class=\"n\">ctx<\/span> <span class=\"n\">context<\/span><span class=\"o\">.<\/span><span class=\"n\">Context<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>\n    <span class=\"n\">topic<\/span> <span class=\"o\">:=<\/span> <span class=\"n\">g<\/span><span class=\"o\">.<\/span><span class=\"n\">Cfg<\/span><span class=\"p\">()<\/span><span class=\"o\">.<\/span><span class=\"n\">MustGet<\/span><span class=\"p\">(<\/span><span class=\"n\">ctx<\/span><span class=\"p\">,<\/span> <span class=\"s\">\"kafka.topic\"<\/span><span class=\"p\">)<\/span><span class=\"o\">.<\/span><span class=\"n\">String<\/span><span class=\"p\">()<\/span>\n    <span class=\"n\">partitionList<\/span><span class=\"p\">,<\/span> <span class=\"n\">err<\/span> <span class=\"o\">:=<\/span> <span class=\"n\">kafkaConsumer<\/span><span class=\"o\">.<\/span><span class=\"n\">Partitions<\/span><span class=\"p\">(<\/span><span class=\"n\">topic<\/span><span class=\"p\">)<\/span>\n    <span class=\"k\">if<\/span> <span class=\"n\">err<\/span> <span class=\"o\">!=<\/span> <span class=\"no\">nil<\/span> <span class=\"p\">{<\/span>\n        <span class=\"n\">g<\/span><span class=\"o\">.<\/span><span class=\"n\">Log<\/span><span class=\"p\">()<\/span><span class=\"o\">.<\/span><span class=\"n\">Errorf<\/span><span class=\"p\">(<\/span><span class=\"n\">ctx<\/span><span class=\"p\">,<\/span> <span class=\"s\">\"Failed to get partition list: %v\"<\/span><span class=\"p\">,<\/span> <span class=\"n\">err<\/span><span class=\"p\">)<\/span>\n        <span class=\"k\">return<\/span>\n    <span class=\"p\">}<\/span>\n\n    <span class=\"c\">\/\/ Create a channel to handle shutdown<\/span>\n    <span class=\"n\">done<\/span> <span class=\"o\">:=<\/span> <span class=\"nb\">make<\/span><span class=\"p\">(<\/span><span class=\"k\">chan<\/span> <span class=\"kt\">bool<\/span><span class=\"p\">)<\/span>\n\n    <span class=\"k\">for<\/span> <span class=\"n\">partition<\/span> <span class=\"o\">:=<\/span> <span class=\"k\">range<\/span> <span class=\"n\">partitionList<\/span> <span class=\"p\">{<\/span>\n        <span class=\"c\">\/\/ Start a goroutine for each partition<\/span>\n        <span class=\"k\">go<\/span> <span class=\"k\">func<\/span><span class=\"p\">(<\/span><span class=\"n\">partition<\/span> <span class=\"kt\">int32<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>\n            <span class=\"n\">pc<\/span><span class=\"p\">,<\/span> <span class=\"n\">err<\/span> <span class=\"o\">:=<\/span> <span class=\"n\">kafkaConsumer<\/span><span class=\"o\">.<\/span><span class=\"n\">ConsumePartition<\/span><span class=\"p\">(<\/span><span class=\"n\">topic<\/span><span class=\"p\">,<\/span> <span class=\"n\">partition<\/span><span class=\"p\">,<\/span> \n                <span class=\"n\">sarama<\/span><span class=\"o\">.<\/span><span class=\"n\">OffsetNewest<\/span><span class=\"p\">)<\/span>\n            <span class=\"k\">if<\/span> <span class=\"n\">err<\/span> <span class=\"o\">!=<\/span> <span class=\"no\">nil<\/span> <span class=\"p\">{<\/span>\n                <span class=\"n\">g<\/span><span class=\"o\">.<\/span><span class=\"n\">Log<\/span><span class=\"p\">()<\/span><span class=\"o\">.<\/span><span class=\"n\">Errorf<\/span><span class=\"p\">(<\/span><span class=\"n\">ctx<\/span><span class=\"p\">,<\/span> <span class=\"s\">\"Failed to start consumer: %v\"<\/span><span class=\"p\">,<\/span> <span class=\"n\">err<\/span><span class=\"p\">)<\/span>\n                <span class=\"k\">return<\/span>\n            <span class=\"p\">}<\/span>\n\n            <span class=\"k\">defer<\/span> <span class=\"n\">pc<\/span><span class=\"o\">.<\/span><span class=\"n\">Close<\/span><span class=\"p\">()<\/span>\n\n            <span class=\"k\">for<\/span> <span class=\"p\">{<\/span>\n                <span class=\"k\">select<\/span> <span class=\"p\">{<\/span>\n                <span class=\"k\">case<\/span> <span class=\"n\">msg<\/span> <span class=\"o\">:=<\/span> <span class=\"o\">&lt;-<\/span><span class=\"n\">pc<\/span><span class=\"o\">.<\/span><span class=\"n\">Messages<\/span><span class=\"p\">()<\/span><span class=\"o\">:<\/span>\n                    <span class=\"n\">handleMessageWithRetry<\/span><span class=\"p\">(<\/span><span class=\"n\">ctx<\/span><span class=\"p\">,<\/span> <span class=\"n\">msg<\/span><span class=\"p\">)<\/span>\n                <span class=\"k\">case<\/span> <span class=\"o\">&lt;-<\/span><span class=\"n\">ctx<\/span><span class=\"o\">.<\/span><span class=\"n\">Done<\/span><span class=\"p\">()<\/span><span class=\"o\">:<\/span>\n                    <span class=\"n\">done<\/span> <span class=\"o\">&lt;-<\/span> <span class=\"no\">true<\/span>\n                    <span class=\"k\">return<\/span>\n                <span class=\"p\">}<\/span>\n            <span class=\"p\">}<\/span>\n        <span class=\"p\">}(<\/span><span class=\"kt\">int32<\/span><span class=\"p\">(<\/span><span class=\"n\">partition<\/span><span class=\"p\">))<\/span>\n    <span class=\"p\">}<\/span>\n\n    <span class=\"o\">&lt;-<\/span><span class=\"n\">done<\/span> <span class=\"c\">\/\/ Wait for shutdown signal<\/span>\n<span class=\"p\">}<\/span>\n<\/code><\/pre>\n<div class=\"highlight__panel js-actions-panel\">\n<div class=\"highlight__panel-action js-fullscreen-code-action\">\n    <svg xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"20px\" height=\"20px\" viewbox=\"0 0 24 24\" class=\"highlight-action crayons-icon highlight-action--fullscreen-on\"><title>\u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u0631\u0627 \u0648\u0627\u0631\u062f \u06a9\u0646\u06cc\u062f<\/title>\n    <path d=\"M16 3h6v6h-2V5h-4V3zM2 3h6v2H4v4H2V3zm18 16v-4h2v6h-6v-2h4zM4 19h4v2H2v-6h2v4z\"\/>\n<\/svg><\/p>\n<p>    <svg xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"20px\" height=\"20px\" viewbox=\"0 0 24 24\" class=\"highlight-action crayons-icon highlight-action--fullscreen-off\"><title>\u0627\u0632 \u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u062e\u0627\u0631\u062c \u0634\u0648\u06cc\u062f<\/title>\n    <path d=\"M18 7h4v2h-6V3h2v4zM8 9H2V7h4V3h2v6zm10 8v4h-2v-6h6v2h-4zM8 15v6H6v-4H2v-2h6z\"\/>\n<\/svg><\/p>\n<\/div>\n<\/div>\n<\/div>\n<h3><span class=\"ez-toc-section\" id=\"%D8%A7%D9%81%D8%B2%D9%88%D8%AF%D9%86_%D9%85%D9%86%D8%B7%D9%82_%D8%A2%D8%B2%D9%85%D8%A7%DB%8C%D8%B4_%D9%85%D8%AC%D8%AF%D8%AF\"><\/span>\n<p>  \u0627\u0641\u0632\u0648\u062f\u0646 \u0645\u0646\u0637\u0642 \u0622\u0632\u0645\u0627\u06cc\u0634 \u0645\u062c\u062f\u062f<br \/>\n<span class=\"ez-toc-section-end\"><\/span><\/h3>\n<p>\u062f\u0631 \u0627\u06cc\u0646\u062c\u0627 \u06cc\u06a9 \u0645\u06a9\u0627\u0646\u06cc\u0632\u0645 \u0622\u0632\u0645\u0627\u06cc\u0634\u06af\u0627\u0647 \u0642\u0648\u06cc \u0628\u0631\u0627\u06cc \u0631\u0633\u06cc\u062f\u06af\u06cc \u0628\u0647 \u062e\u0631\u0627\u0628\u06cc \u0647\u0627\u06cc \u067e\u0631\u062f\u0627\u0632\u0634 \u067e\u06cc\u0627\u0645 \u0648\u062c\u0648\u062f \u062f\u0627\u0631\u062f:<\/p>\n<div class=\"highlight js-code-highlight\">\n<pre class=\"highlight go\"><code><span class=\"k\">const<\/span> <span class=\"p\">(<\/span>\n    <span class=\"n\">maxRetries<\/span> <span class=\"o\">=<\/span> <span class=\"m\">3<\/span>\n    <span class=\"n\">retryDelay<\/span> <span class=\"o\">=<\/span> <span class=\"n\">time<\/span><span class=\"o\">.<\/span><span class=\"n\">Second<\/span>\n<span class=\"p\">)<\/span>\n\n<span class=\"k\">func<\/span> <span class=\"n\">handleMessageWithRetry<\/span><span class=\"p\">(<\/span><span class=\"n\">ctx<\/span> <span class=\"n\">context<\/span><span class=\"o\">.<\/span><span class=\"n\">Context<\/span><span class=\"p\">,<\/span> <span class=\"n\">msg<\/span> <span class=\"o\">*<\/span><span class=\"n\">sarama<\/span><span class=\"o\">.<\/span><span class=\"n\">ConsumerMessage<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>\n    <span class=\"k\">var<\/span> <span class=\"n\">err<\/span> <span class=\"kt\">error<\/span>\n    <span class=\"k\">for<\/span> <span class=\"n\">attempt<\/span> <span class=\"o\">:=<\/span> <span class=\"m\">0<\/span><span class=\"p\">;<\/span> <span class=\"n\">attempt<\/span> <span class=\"o\">&lt;<\/span> <span class=\"n\">maxRetries<\/span><span class=\"p\">;<\/span> <span class=\"n\">attempt<\/span><span class=\"o\">++<\/span> <span class=\"p\">{<\/span>\n        <span class=\"n\">err<\/span> <span class=\"o\">=<\/span> <span class=\"n\">processMessage<\/span><span class=\"p\">(<\/span><span class=\"n\">ctx<\/span><span class=\"p\">,<\/span> <span class=\"n\">msg<\/span><span class=\"p\">)<\/span>\n        <span class=\"k\">if<\/span> <span class=\"n\">err<\/span> <span class=\"o\">==<\/span> <span class=\"no\">nil<\/span> <span class=\"p\">{<\/span>\n            <span class=\"c\">\/\/ Success! Let's mark the message as processed<\/span>\n            <span class=\"n\">markMessageProcessed<\/span><span class=\"p\">(<\/span><span class=\"n\">msg<\/span><span class=\"p\">)<\/span>\n            <span class=\"k\">return<\/span>\n        <span class=\"p\">}<\/span>\n\n        <span class=\"n\">g<\/span><span class=\"o\">.<\/span><span class=\"n\">Log<\/span><span class=\"p\">()<\/span><span class=\"o\">.<\/span><span class=\"n\">Warningf<\/span><span class=\"p\">(<\/span><span class=\"n\">ctx<\/span><span class=\"p\">,<\/span> \n            <span class=\"s\">\"Failed to process message (attempt %d\/%d): %v\"<\/span><span class=\"p\">,<\/span> \n            <span class=\"n\">attempt<\/span><span class=\"o\">+<\/span><span class=\"m\">1<\/span><span class=\"p\">,<\/span> <span class=\"n\">maxRetries<\/span><span class=\"p\">,<\/span> <span class=\"n\">err<\/span><span class=\"p\">)<\/span>\n\n        <span class=\"k\">if<\/span> <span class=\"n\">attempt<\/span> <span class=\"o\">&lt;<\/span> <span class=\"n\">maxRetries<\/span><span class=\"o\">-<\/span><span class=\"m\">1<\/span> <span class=\"p\">{<\/span>\n            <span class=\"n\">time<\/span><span class=\"o\">.<\/span><span class=\"n\">Sleep<\/span><span class=\"p\">(<\/span><span class=\"n\">retryDelay<\/span> <span class=\"o\">*<\/span> <span class=\"n\">time<\/span><span class=\"o\">.<\/span><span class=\"n\">Duration<\/span><span class=\"p\">(<\/span><span class=\"n\">attempt<\/span><span class=\"o\">+<\/span><span class=\"m\">1<\/span><span class=\"p\">))<\/span>\n        <span class=\"p\">}<\/span>\n    <span class=\"p\">}<\/span>\n\n    <span class=\"c\">\/\/ If we get here, all retries failed<\/span>\n    <span class=\"n\">g<\/span><span class=\"o\">.<\/span><span class=\"n\">Log<\/span><span class=\"p\">()<\/span><span class=\"o\">.<\/span><span class=\"n\">Errorf<\/span><span class=\"p\">(<\/span><span class=\"n\">ctx<\/span><span class=\"p\">,<\/span> \n        <span class=\"s\">\"Failed to process message after %d attempts: %v\"<\/span><span class=\"p\">,<\/span> \n        <span class=\"n\">maxRetries<\/span><span class=\"p\">,<\/span> <span class=\"n\">err<\/span><span class=\"p\">)<\/span>\n\n    <span class=\"c\">\/\/ Here you might want to:<\/span>\n    <span class=\"c\">\/\/ 1. Send to a dead letter queue<\/span>\n    <span class=\"c\">\/\/ 2. Store in an error log<\/span>\n    <span class=\"c\">\/\/ 3. Trigger an alert<\/span>\n    <span class=\"n\">handleFailedMessage<\/span><span class=\"p\">(<\/span><span class=\"n\">ctx<\/span><span class=\"p\">,<\/span> <span class=\"n\">msg<\/span><span class=\"p\">,<\/span> <span class=\"n\">err<\/span><span class=\"p\">)<\/span>\n<span class=\"p\">}<\/span>\n<\/code><\/pre>\n<div class=\"highlight__panel js-actions-panel\">\n<div class=\"highlight__panel-action js-fullscreen-code-action\">\n    <svg xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"20px\" height=\"20px\" viewbox=\"0 0 24 24\" class=\"highlight-action crayons-icon highlight-action--fullscreen-on\"><title>\u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u0631\u0627 \u0648\u0627\u0631\u062f \u06a9\u0646\u06cc\u062f<\/title>\n    <path d=\"M16 3h6v6h-2V5h-4V3zM2 3h6v2H4v4H2V3zm18 16v-4h2v6h-6v-2h4zM4 19h4v2H2v-6h2v4z\"\/>\n<\/svg><\/p>\n<p>    <svg xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"20px\" height=\"20px\" viewbox=\"0 0 24 24\" class=\"highlight-action crayons-icon highlight-action--fullscreen-off\"><title>\u0627\u0632 \u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u062e\u0627\u0631\u062c \u0634\u0648\u06cc\u062f<\/title>\n    <path d=\"M18 7h4v2h-6V3h2v4zM8 9H2V7h4V3h2v6zm10 8v4h-2v-6h6v2h-4zM8 15v6H6v-4H2v-2h6z\"\/>\n<\/svg><\/p>\n<\/div>\n<\/div>\n<\/div>\n<h2><span class=\"ez-toc-section\" id=\"%D9%86%DA%A9%D8%A7%D8%AA_%D8%AD%D8%B1%D9%81%D9%87_%D8%A7%DB%8C\"><\/span>\n<p>  \u0646\u06a9\u0627\u062a \u062d\u0631\u0641\u0647 \u0627\u06cc<br \/>\n<span class=\"ez-toc-section-end\"><\/span><\/h2>\n<p><strong>\u0628\u0627\u063a \u0648\u062d\u0634 \u0627\u0648\u0644<\/strong>: \u0647\u0645\u06cc\u0634\u0647 \u0627\u0637\u0645\u06cc\u0646\u0627\u0646 \u062d\u0627\u0635\u0644 \u06a9\u0646\u06cc\u062f \u06a9\u0647 Zookeeper \u0642\u0628\u0644 \u0627\u0632 \u0634\u0631\u0648\u0639 \u06a9\u0627\u0641\u06a9\u0627 \u062f\u0631 \u062d\u0627\u0644 \u0627\u062c\u0631\u0627 \u0627\u0633\u062a:<\/p>\n<div class=\"highlight js-code-highlight\">\n<pre class=\"highlight shell\"><code>   <span class=\"c\"># Start ZooKeeper first<\/span>\n   .\/zookeeper-server-start.sh config\/zookeeper.properties\n\n   <span class=\"c\"># Then start Kafka<\/span>\n   .\/kafka-server-start.sh config\/server.properties\n<\/code><\/pre>\n<div class=\"highlight__panel js-actions-panel\">\n<div class=\"highlight__panel-action js-fullscreen-code-action\">\n    <svg xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"20px\" height=\"20px\" viewbox=\"0 0 24 24\" class=\"highlight-action crayons-icon highlight-action--fullscreen-on\"><title>\u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u0631\u0627 \u0648\u0627\u0631\u062f \u06a9\u0646\u06cc\u062f<\/title>\n    <path d=\"M16 3h6v6h-2V5h-4V3zM2 3h6v2H4v4H2V3zm18 16v-4h2v6h-6v-2h4zM4 19h4v2H2v-6h2v4z\"\/>\n<\/svg><\/p>\n<p>    <svg xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"20px\" height=\"20px\" viewbox=\"0 0 24 24\" class=\"highlight-action crayons-icon highlight-action--fullscreen-off\"><title>\u0627\u0632 \u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u062e\u0627\u0631\u062c \u0634\u0648\u06cc\u062f<\/title>\n    <path d=\"M18 7h4v2h-6V3h2v4zM8 9H2V7h4V3h2v6zm10 8v4h-2v-6h6v2h-4zM8 15v6H6v-4H2v-2h6z\"\/>\n<\/svg><\/p>\n<\/div>\n<\/div>\n<\/div>\n<p><strong>\u0645\u0635\u0631\u0641 \u06a9\u0646\u0646\u062f\u06af\u0627\u0646 \u062e\u0648\u062f \u0631\u0627 \u06a9\u0646\u062a\u0631\u0644 \u06a9\u0646\u06cc\u062f<\/strong>: \u0628\u0631\u0627\u06cc \u0627\u0637\u0645\u06cc\u0646\u0627\u0646 \u0627\u0632 \u0627\u06cc\u0646\u06a9\u0647 \u0633\u06cc\u0633\u062a\u0645 \u0634\u0645\u0627 \u0628\u0627 \u062c\u0631\u06cc\u0627\u0646 \u067e\u06cc\u0627\u0645 \u0647\u0645\u0631\u0627\u0647 \u0627\u0633\u062a \u060c \u062a\u0627\u062e\u06cc\u0631 \u0645\u0635\u0631\u0641 \u06a9\u0646\u0646\u062f\u0647 \u0631\u0627 \u067e\u06cc\u06af\u06cc\u0631\u06cc \u06a9\u0646\u06cc\u062f.<\/p>\n<p><strong>\u062e\u0627\u0645\u0648\u0634 \u06a9\u0631\u062f\u0646 \u0628\u0631\u0627\u0632\u0646\u062f\u0647<\/strong>: \u0647\u0645\u06cc\u0634\u0647 \u062a\u0648\u0644\u06cc\u062f \u06a9\u0646\u0646\u062f\u06af\u0627\u0646 \u0648 \u0645\u0635\u0631\u0641 \u06a9\u0646\u0646\u062f\u06af\u0627\u0646 \u062e\u0648\u062f \u0631\u0627 \u0628\u0647 \u062f\u0631\u0633\u062a\u06cc \u0628\u0628\u0646\u062f\u06cc\u062f:<\/p>\n<div class=\"highlight js-code-highlight\">\n<pre class=\"highlight go\"><code>   <span class=\"k\">defer<\/span> <span class=\"k\">func<\/span><span class=\"p\">()<\/span> <span class=\"p\">{<\/span>\n       <span class=\"k\">if<\/span> <span class=\"n\">err<\/span> <span class=\"o\">:=<\/span> <span class=\"n\">kafkaProducer<\/span><span class=\"o\">.<\/span><span class=\"n\">Close<\/span><span class=\"p\">();<\/span> <span class=\"n\">err<\/span> <span class=\"o\">!=<\/span> <span class=\"no\">nil<\/span> <span class=\"p\">{<\/span>\n           <span class=\"n\">g<\/span><span class=\"o\">.<\/span><span class=\"n\">Log<\/span><span class=\"p\">()<\/span><span class=\"o\">.<\/span><span class=\"n\">Errorf<\/span><span class=\"p\">(<\/span><span class=\"n\">ctx<\/span><span class=\"p\">,<\/span> <span class=\"s\">\"Failed to close producer: %v\"<\/span><span class=\"p\">,<\/span> <span class=\"n\">err<\/span><span class=\"p\">)<\/span>\n       <span class=\"p\">}<\/span>\n       <span class=\"k\">if<\/span> <span class=\"n\">err<\/span> <span class=\"o\">:=<\/span> <span class=\"n\">kafkaConsumer<\/span><span class=\"o\">.<\/span><span class=\"n\">Close<\/span><span class=\"p\">();<\/span> <span class=\"n\">err<\/span> <span class=\"o\">!=<\/span> <span class=\"no\">nil<\/span> <span class=\"p\">{<\/span>\n           <span class=\"n\">g<\/span><span class=\"o\">.<\/span><span class=\"n\">Log<\/span><span class=\"p\">()<\/span><span class=\"o\">.<\/span><span class=\"n\">Errorf<\/span><span class=\"p\">(<\/span><span class=\"n\">ctx<\/span><span class=\"p\">,<\/span> <span class=\"s\">\"Failed to close consumer: %v\"<\/span><span class=\"p\">,<\/span> <span class=\"n\">err<\/span><span class=\"p\">)<\/span>\n       <span class=\"p\">}<\/span>\n   <span class=\"p\">}()<\/span>\n<\/code><\/pre>\n<div class=\"highlight__panel js-actions-panel\">\n<div class=\"highlight__panel-action js-fullscreen-code-action\">\n    <svg xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"20px\" height=\"20px\" viewbox=\"0 0 24 24\" class=\"highlight-action crayons-icon highlight-action--fullscreen-on\"><title>\u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u0631\u0627 \u0648\u0627\u0631\u062f \u06a9\u0646\u06cc\u062f<\/title>\n    <path d=\"M16 3h6v6h-2V5h-4V3zM2 3h6v2H4v4H2V3zm18 16v-4h2v6h-6v-2h4zM4 19h4v2H2v-6h2v4z\"\/>\n<\/svg><\/p>\n<p>    <svg xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"20px\" height=\"20px\" viewbox=\"0 0 24 24\" class=\"highlight-action crayons-icon highlight-action--fullscreen-off\"><title>\u0627\u0632 \u062d\u0627\u0644\u062a \u062a\u0645\u0627\u0645 \u0635\u0641\u062d\u0647 \u062e\u0627\u0631\u062c \u0634\u0648\u06cc\u062f<\/title>\n    <path d=\"M18 7h4v2h-6V3h2v4zM8 9H2V7h4V3h2v6zm10 8v4h-2v-6h6v2h-4zM8 15v6H6v-4H2v-2h6z\"\/>\n<\/svg><\/p>\n<\/div>\n<\/div>\n<\/div>\n<h2><span class=\"ez-toc-section\" id=\"%DA%86%D9%87_%DA%86%DB%8C%D8%B2%DB%8C_%D8%A8%D8%B9%D8%AF%DB%8C%D8%9F_%F0%9F%9A%80\"><\/span>\n<p>  \u0686\u0647 \u0686\u06cc\u0632\u06cc \u0628\u0639\u062f\u06cc\u061f \ud83d\ude80<br \/>\n<span class=\"ez-toc-section-end\"><\/span><\/h2>\n<p>\u0627\u06a9\u0646\u0648\u0646 \u06a9\u0647 \u06cc\u06a9 \u067e\u0627\u06cc\u0647 \u0645\u062d\u06a9\u0645 \u062f\u0627\u0631\u06cc\u062f \u060c \u0645\u0645\u06a9\u0646 \u0627\u0633\u062a \u0628\u062e\u0648\u0627\u0647\u06cc\u062f \u0627\u06a9\u062a\u0634\u0627\u0641 \u06a9\u0646\u06cc\u062f:<\/p>\n<ul>\n<li>\u062a\u0646\u0638\u06cc\u0645 \u0641\u0634\u0631\u062f\u0647 \u0633\u0627\u0632\u06cc \u067e\u06cc\u0627\u0645 \u0628\u0631\u0627\u06cc \u0639\u0645\u0644\u06a9\u0631\u062f \u0628\u0647\u062a\u0631<\/li>\n<li>\u0627\u062c\u0631\u0627\u06cc \u0635\u0641 \u0646\u0627\u0645\u0647 \u0647\u0627\u06cc \u0645\u0631\u062f\u0647 \u0628\u0631\u0627\u06cc \u067e\u06cc\u0627\u0645 \u0647\u0627\u06cc \u0646\u0627\u0645\u0648\u0641\u0642<\/li>\n<li>\u0627\u0636\u0627\u0641\u0647 \u06a9\u0631\u062f\u0646 \u0645\u0639\u06cc\u0627\u0631\u0647\u0627 \u0648 \u0646\u0638\u0627\u0631\u062a<\/li>\n<li>\u0631\u0627\u0647 \u0627\u0646\u062f\u0627\u0632\u06cc \u0686\u0646\u062f\u06cc\u0646 \u06af\u0631\u0648\u0647 \u0645\u0635\u0631\u0641 \u06a9\u0646\u0646\u062f\u0647<\/li>\n<\/ul>\n<h2><span class=\"ez-toc-section\" id=\"%D8%A8%D8%B3%D8%AA%D9%87_%D8%A8%D9%86%D8%AF%DB%8C\"><\/span>\n<p>  \u0628\u0633\u062a\u0647 \u0628\u0646\u062f\u06cc<br \/>\n<span class=\"ez-toc-section-end\"><\/span><\/h2>\n<p>\u0645\u0627 \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 Kafka \u0648 Goframe \u06cc\u06a9 \u0633\u06cc\u0633\u062a\u0645 \u0635\u0641 \u067e\u06cc\u0627\u0645 \u0642\u0648\u06cc \u0627\u06cc\u062c\u0627\u062f \u06a9\u0631\u062f\u0647 \u0627\u06cc\u0645! \u0627\u06cc\u0646 \u062a\u0631\u06a9\u06cc\u0628 \u06cc\u06a9 \u0631\u0627\u0647 \u062d\u0644 \u0645\u0642\u06cc\u0627\u0633 \u067e\u0630\u06cc\u0631 \u0648 \u0642\u0627\u0628\u0644 \u0627\u0639\u062a\u0645\u0627\u062f \u0628\u0631\u0627\u06cc \u0631\u0633\u06cc\u062f\u06af\u06cc \u0628\u0647 \u067e\u0631\u062f\u0627\u0632\u0634 \u067e\u06cc\u0627\u0645 \u0628\u0627 \u062a\u0648\u0627\u0646 \u0628\u0627\u0644\u0627 \u0627\u0631\u0627\u0626\u0647 \u0645\u06cc \u062f\u0647\u062f.<\/p>\n<p>\u0622\u06cc\u0627 \u06a9\u0627\u0641\u06a9\u0627 \u0631\u0627 \u062f\u0631 \u067e\u0631\u0648\u0698\u0647 \u0647\u0627\u06cc GO \u062e\u0648\u062f \u067e\u06cc\u0627\u062f\u0647 \u0633\u0627\u0632\u06cc \u06a9\u0631\u062f\u0647 \u0627\u06cc\u062f\u061f \u0628\u0627 \u0686\u0647 \u0686\u0627\u0644\u0634 \u0647\u0627\u06cc\u06cc \u0631\u0648\u0628\u0631\u0648 \u0634\u062f\u06cc\u062f\u061f \u062a\u062c\u0631\u0628\u06cc\u0627\u062a \u062e\u0648\u062f \u0631\u0627 \u062f\u0631 \u0646\u0638\u0631\u0627\u062a \u0632\u06cc\u0631 \u0628\u0647 \u0627\u0634\u062a\u0631\u0627\u06a9 \u0628\u06af\u0630\u0627\u0631\u06cc\u062f! \ud83d\udc47<\/p>\n<hr\/>\n<p>\u0627\u06cc\u0646 \u0645\u0641\u06cc\u062f \u0627\u0633\u062a\u061f \u0628\u0631\u0627\u06cc \u0622\u0645\u0648\u0632\u0634 \u0628\u06cc\u0634\u062a\u0631 \u0645\u0631\u0627 \u062f\u0646\u0628\u0627\u0644 \u06a9\u0646\u06cc\u062f \u0648 \u0641\u0631\u0627\u0645\u0648\u0634 \u0646\u06a9\u0646\u06cc\u062f \u06a9\u0647 \u0627\u06cc\u0646 \u067e\u0633\u062a!<\/p>\n<\/p><\/div>\n","protected":false},"excerpt":{"rendered":"<p>\u0633\u0644\u0627\u0645 Devs \u0647\u0645\u06a9\u0627\u0631! \ud83d\udc4b \u0627\u0645\u0631\u0648\u0632 \u060c \u0645\u0627 \u062f\u0631 \u062d\u0627\u0644 \u062a\u0628\u062f\u06cc\u0644 \u0634\u062f\u0646 \u0628\u0647 \u0646\u062d\u0648\u0647 \u0633\u0627\u062e\u062a \u06cc\u06a9 \u0633\u06cc\u0633\u062a\u0645 \u0635\u0641 \u067e\u06cc\u0627\u0645 \u0642\u0648\u06cc \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 Apache Kafka \u0628\u0627 \u0686\u0627\u0631\u0686\u0648\u0628 Goframe \u0647\u0633\u062a\u06cc\u0645. \u0627\u06cc\u0646 \u06a9\u0647 \u0622\u06cc\u0627 \u0634\u0645\u0627 \u062f\u0631 \u062d\u0627\u0644 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 \u062c\u0631\u06cc\u0627\u0646 \u062f\u0627\u062f\u0647 \u0647\u0627\u06cc \u0628\u0627 \u062a\u0648\u0627\u0646 \u0628\u0627\u0644\u0627 \u060c \u0633\u0627\u062e\u062a\u0645\u0627\u0646 \u0645\u0639\u0645\u0627\u0631\u06cc \u0647\u0627\u06cc \u0645\u062d\u0648\u0631 \u0631\u0648\u06cc\u062f\u0627\u062f \u0647\u0633\u062a\u06cc\u062f \u060c \u06cc\u0627 \u0641\u0642\u0637 \u0645\u06cc \u062e\u0648\u0627\u0647\u06cc\u062f \u062e\u062f\u0645\u0627\u062a &hellip;<\/p>\n","protected":false},"author":2,"featured_media":100770,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"fifu_image_url":"","fifu_image_alt":"","footnotes":""},"categories":[339],"tags":[],"class_list":["post-100769","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-dev"],"_links":{"self":[{"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/posts\/100769","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/comments?post=100769"}],"version-history":[{"count":0,"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/posts\/100769\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/media\/100770"}],"wp:attachment":[{"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/media?parent=100769"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/categories?post=100769"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/tags?post=100769"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}