{"id":5394,"date":"2025-04-30T10:00:45","date_gmt":"2025-04-30T06:30:45","guid":{"rendered":"https:\/\/parmin.cloud\/blog\/?p=5394"},"modified":"2025-04-22T10:34:32","modified_gmt":"2025-04-22T07:04:32","slug":"%da%86%d8%b7%d9%88%d8%b1-apache-kafka-%d8%b1%d8%a7-%d8%a8%d9%87%d8%b5%d9%88%d8%b1%d8%aa-%d8%ad%d8%b1%d9%81%d9%87-%d8%a7%db%8c-%d9%85%d8%af%db%8c%d8%b1%db%8c%d8%aa-%da%a9%d9%86%db%8c%d9%85","status":"publish","type":"post","link":"https:\/\/parmin.cloud\/blog\/%da%86%d8%b7%d9%88%d8%b1-apache-kafka-%d8%b1%d8%a7-%d8%a8%d9%87%d8%b5%d9%88%d8%b1%d8%aa-%d8%ad%d8%b1%d9%81%d9%87-%d8%a7%db%8c-%d9%85%d8%af%db%8c%d8%b1%db%8c%d8%aa-%da%a9%d9%86%db%8c%d9%85\/","title":{"rendered":"\u0686\u0637\u0648\u0631 Apache Kafka \u0631\u0627 \u0628\u0647\u200c\u0635\u0648\u0631\u062a \u062d\u0631\u0641\u0647 \u0627\u06cc \u0645\u062f\u06cc\u0631\u06cc\u062a \u06a9\u0646\u06cc\u0645 \u061f"},"content":{"rendered":"
\u0645\u0642\u062f\u0645\u0647<\/span><\/div>\n
Apache Kafka \u06cc\u06a9 \u067e\u0644\u062a\u0641\u0631\u0645 \u067e\u0631\u062f\u0627\u0632\u0634 \u0631\u0648\u06cc\u062f\u0627\u062f \u0648 \u062c\u0631\u06cc\u0627\u0646 \u062a\u0648\u0632\u06cc\u0639\u200c\u0634\u062f\u0647 \u0648 \u0645\u062a\u0646\u200c\u0628\u0627\u0632 \u0627\u0633\u062a \u06a9\u0647 \u0628\u0627 \u0632\u0628\u0627\u0646 \u062c\u0627\u0648\u0627 \u0646\u0648\u0634\u062a\u0647 \u0634\u062f\u0647 \u0627\u0633\u062a. \u0627\u06cc\u0646 \u067e\u0644\u062a\u0641\u0631\u0645 \u0628\u0631\u0627\u06cc \u067e\u0631\u062f\u0627\u0632\u0634 \u062f\u0627\u062f\u0647\u200c\u0647\u0627\u06cc \u0632\u0645\u0627\u0646 \u0648\u0627\u0642\u0639\u06cc \u06a9\u0647 \u0646\u06cc\u0627\u0632 \u0628\u0647 \u0645\u0646\u0627\u0628\u0639 \u0632\u06cc\u0627\u062f\u06cc \u062f\u0627\u0631\u0646\u062f \u0637\u0631\u0627\u062d\u06cc \u0634\u062f\u0647 \u0627\u0633\u062a \u0648 \u0628\u0647\u200c\u0637\u0648\u0631 \u0630\u0627\u062a\u06cc \u0645\u0642\u06cc\u0627\u0633\u200c\u067e\u0630\u06cc\u0631 \u0627\u0633\u062a \u0648 \u0627\u0632 \u0637\u0631\u06cc\u0642 \u062a\u0648\u0627\u0646 \u0639\u0645\u0644\u06cc\u0627\u062a\u06cc \u0648 \u062f\u0631 \u062f\u0633\u062a\u0631\u0633 \u0628\u0648\u062f\u0646 \u0628\u0627\u0644\u0627 \u0628\u0647\u0631\u0647 \u0645\u06cc\u200c\u0628\u0631\u062f. \u0627\u06cc\u0646 \u067e\u0631\u0648\u0698\u0647 \u0627\u0633\u06a9\u0631\u06cc\u067e\u062a\u200c\u0647\u0627\u06cc \u0634\u0644 \u0631\u0627 \u0628\u0631\u0627\u06cc \u062a\u0648\u0644\u06cc\u062f \u0648 \u0645\u0635\u0631\u0641 \u067e\u06cc\u0627\u0645\u200c\u0647\u0627 \u0627\u0632 \u06cc\u06a9 \u06a9\u0644\u0627\u0633\u062a\u0631 Kafka \u0648 \u0627\u0646\u062c\u0627\u0645 \u0648\u0638\u0627\u06cc\u0641 \u0645\u062f\u06cc\u0631\u06cc\u062a\u06cc \u0645\u0627\u0646\u0646\u062f \u0645\u062f\u06cc\u0631\u06cc\u062a \u0645\u0648\u0636\u0648\u0639\u0627\u062a \u0648 \u067e\u0627\u0631\u062a\u06cc\u0634\u0646\u200c\u0647\u0627 \u0627\u0631\u0627\u0626\u0647 \u0645\u06cc\u200c\u062f\u0647\u062f. \u062f\u0631 \u062d\u0627\u0644\u06cc \u06a9\u0647 \u0627\u06cc\u0646 \u0627\u0633\u06a9\u0631\u06cc\u067e\u062a\u200c\u0647\u0627 \u0628\u0631\u0627\u06cc \u06a9\u0627\u0648\u0634 \u0648 \u0622\u0632\u0645\u0627\u06cc\u0634 \u0645\u0641\u06cc\u062f \u0647\u0633\u062a\u0646\u062f\u060c \u062f\u0631 \u0628\u0631\u0646\u0627\u0645\u0647\u200c\u0647\u0627\u06cc \u062f\u0646\u06cc\u0627\u06cc \u0648\u0627\u0642\u0639\u06cc \u062f\u0633\u062a\u0631\u0633\u06cc \u0628\u0647 Kafka \u0628\u0647\u200c\u0635\u0648\u0631\u062a \u0628\u0631\u0646\u0627\u0645\u0647\u200c\u0646\u0648\u06cc\u0633\u06cc \u0627\u0646\u062c\u0627\u0645 \u0645\u06cc\u200c\u0634\u0648\u062f. \u0628\u0631\u0627\u06cc \u0627\u06cc\u0646 \u0645\u0646\u0638\u0648\u0631\u060c Kafka \u06a9\u062a\u0627\u0628\u062e\u0627\u0646\u0647\u200c\u0647\u0627\u06cc \u06a9\u0644\u0627\u06cc\u0646\u062a \u0632\u06cc\u0627\u062f\u06cc \u0628\u0631\u0627\u06cc \u0632\u0628\u0627\u0646\u200c\u0647\u0627\u06cc \u0628\u0631\u0646\u0627\u0645\u0647\u200c\u0646\u0648\u06cc\u0633\u06cc \u0648 \u0645\u062d\u06cc\u0637\u200c\u0647\u0627\u06cc widely-used \u0641\u0631\u0627\u0647\u0645 \u06a9\u0631\u062f\u0647 \u0627\u0633\u062a.<\/span><\/div>\n
\u062f\u0631 \u0627\u06cc\u0646 \u0622\u0645\u0648\u0632\u0634\u060c \u0634\u0645\u0627 \u06cc\u0627\u062f \u062e\u0648\u0627\u0647\u06cc\u062f \u06af\u0631\u0641\u062a \u06a9\u0647 \u0686\u06af\u0648\u0646\u0647 \u0645\u0646\u0627\u0628\u0639 \u0631\u0627 \u062f\u0631 \u06cc\u06a9 \u06a9\u0644\u0627\u0633\u062a\u0631 Kafka \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 KafkaAdminClient API \u0645\u062f\u06cc\u0631\u06cc\u062a \u06a9\u0646\u06cc\u062f. \u0647\u0645\u0686\u0646\u06cc\u0646 \u06cc\u0627\u062f \u062e\u0648\u0627\u0647\u06cc\u062f \u06af\u0631\u0641\u062a \u06a9\u0647 \u0686\u06af\u0648\u0646\u0647 \u0627\u0637\u0644\u0627\u0639\u0627\u062a \u0645\u0631\u0628\u0648\u0637 \u0628\u0647 \u06a9\u0644\u0627\u0633\u062a\u0631 \u0631\u0627 \u0628\u0647\u200c\u0635\u0648\u0631\u062a \u0628\u0631\u0646\u0627\u0645\u0647\u200c\u0646\u0648\u06cc\u0633\u06cc \u0628\u0627\u0632\u06cc\u0627\u0628\u06cc \u06a9\u0646\u06cc\u062f \u0648 \u0686\u06af\u0648\u0646\u0647 \u0645\u0648\u0636\u0648\u0639\u0627\u062a \u0631\u0627 \u0627\u06cc\u062c\u0627\u062f\u060c \u0641\u0647\u0631\u0633\u062a \u0648 \u062d\u0630\u0641 \u06a9\u0646\u06cc\u062f. \u062f\u0631 \u0646\u0647\u0627\u06cc\u062a\u060c \u0634\u0645\u0627 \u0628\u0627 \u0627\u0628\u0632\u0627\u0631 \u062e\u0637 \u0641\u0631\u0645\u0627\u0646 kcat \u0622\u0634\u0646\u0627 \u062e\u0648\u0627\u0647\u06cc\u062f \u0634\u062f \u06a9\u0647 \u0628\u0647 \u0634\u0645\u0627 \u0627\u06cc\u0646 \u0627\u0645\u06a9\u0627\u0646 \u0631\u0627 \u0645\u06cc\u200c\u062f\u0647\u062f \u062a\u0627 \u0628\u062f\u0648\u0646 \u0648\u0627\u0628\u0633\u062a\u06af\u06cc \u0628\u0647 \u062c\u0627\u0648\u0627 \u0628\u0647 \u06a9\u0644\u0627\u0633\u062a\u0631 Kafka \u062e\u0648\u062f \u062f\u0633\u062a\u0631\u0633\u06cc \u067e\u06cc\u062f\u0627 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
\u062f\u0631 \u0646\u0647\u0627\u06cc\u062a\u060c \u0634\u0645\u0627 \u06cc\u0627\u062f \u062e\u0648\u0627\u0647\u06cc\u062f \u06af\u0631\u0641\u062a \u06a9\u0647 \u0686\u06af\u0648\u0646\u0647 Kafka Cruise Control \u0631\u0627 \u0631\u0627\u0647\u200c\u0627\u0646\u062f\u0627\u0632\u06cc \u06a9\u0646\u06cc\u062f. \u0627\u06cc\u0646 \u06cc\u06a9 \u062f\u06cc\u0645\u0648\u0646 \u0627\u0633\u062a \u06a9\u0647 \u0628\u0647\u200c\u0637\u0648\u0631 \u062e\u0648\u062f\u06a9\u0627\u0631 \u0641\u0631\u0627\u06cc\u0646\u062f\u0647\u0627\u06cc \u062f\u0631\u0648\u0646\u06cc \u06cc\u06a9 \u06a9\u0644\u0627\u0633\u062a\u0631 Kafka \u0631\u0627 \u0628\u0647\u06cc\u0646\u0647 \u0645\u06cc\u200c\u06a9\u0646\u062f \u0648 \u062f\u0631 \u0646\u062a\u06cc\u062c\u0647 \u06a9\u0627\u0631\u0627\u06cc\u06cc \u0648 \u0642\u0627\u0628\u0644\u06cc\u062a \u0627\u0637\u0645\u06cc\u0646\u0627\u0646 \u0628\u0627\u0644\u0627\u062a\u0631\u06cc \u0628\u0647 \u0627\u0631\u0645\u063a\u0627\u0646 \u0645\u06cc\u200c\u0622\u0648\u0631\u062f.<\/span><\/div>\n
<\/div>\n
\u067e\u06cc\u0634\u200c\u0646\u06cc\u0627\u0632\u0647\u0627<\/span><\/div>\n
\u0628\u0631\u0627\u06cc \u062a\u06a9\u0645\u06cc\u0644 \u0627\u06cc\u0646 \u0622\u0645\u0648\u0632\u0634\u060c \u0634\u0645\u0627 \u0628\u0647 \u0645\u0648\u0627\u0631\u062f \u0632\u06cc\u0631 \u0646\u06cc\u0627\u0632 \u062f\u0627\u0631\u06cc\u062f:<\/span><\/div>\n
\u2022 \u06cc\u06a9 \u0645\u0627\u0634\u06cc\u0646 \u0628\u0627 \u062d\u062f\u0627\u0642\u0644 \u06f4 \u06af\u06cc\u06af\u0627\u0628\u0627\u06cc\u062a \u0631\u0645 \u0648 \u06f2 CPU. \u062f\u0631 \u0635\u0648\u0631\u062a\u06cc \u06a9\u0647 \u0627\u0632 \u0633\u0631\u0648\u0631 Ubuntu \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f\u060c \u062f\u0633\u062a\u0648\u0631\u0627\u0644\u0639\u0645\u0644\u200c\u0647\u0627\u06cc \u0631\u0627\u0647\u200c\u0627\u0646\u062f\u0627\u0632\u06cc \u0627\u0648\u0644\u06cc\u0647 \u0633\u0631\u0648\u0631 \u0631\u0627 \u062f\u0646\u0628\u0627\u0644 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
\u2022 \u0646\u0635\u0628 Java Development Kit<\/span> (JDK)<\/span> \u0646\u0633\u062e\u0647 \u06f1\u06f1 \u0628\u0631 \u0631\u0648\u06cc Droplet \u06cc\u0627 \u0645\u0627\u0634\u06cc\u0646 \u0645\u062d\u0644\u06cc \u0634\u0645\u0627. \u0628\u0631\u0627\u06cc \u0631\u0627\u0647\u0646\u0645\u0627\u06cc \u0646\u0635\u0628 \u062c\u0627\u0648\u0627 \u0631\u0648\u06cc Ubuntu\u060c \u0622\u0645\u0648\u0632\u0634<\/span> \u201cHow<\/span> To Install Java with Apt on Ubuntu\u201d \u0631\u0627 \u0645\u0634\u0627\u0647\u062f\u0647 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
\u2022 \u06cc\u06a9 \u06a9\u0644\u0627\u0633\u062a\u0631 Apache Kafka \u0628\u0627 \u0633\u0647 \u0628\u0631\u0648\u06a9\u0631. \u0634\u0645\u0627 \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u06cc\u062f \u0628\u0631\u0627\u06cc \u062f\u0633\u062a\u0648\u0631\u0627\u0644\u0639\u0645\u0644\u200c\u0647\u0627\u06cc \u0631\u0627\u0647\u200c\u0627\u0646\u062f\u0627\u0632\u06cc\u060c \u0622\u0645\u0648\u0632\u0634<\/span> \u201cHow<\/span> To Set Up a Multi-Node Kafka Cluster using KRaft\u201d \u0631\u0627 \u062f\u0646\u0628\u0627\u0644 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
\u2022 \u06cc\u06a9 \u067e\u0631\u0648\u0698\u0647 \u062c\u0627\u0648\u0627 \u0628\u0627 \u06cc\u06a9 Kafka producer \u06a9\u0647 \u0645\u0637\u0627\u0628\u0642 \u0628\u0627 \u0622\u0645\u0648\u0632\u0634<\/span> \u201cHow<\/span> To Set Up a Kafka Producer to Source Data Through CLI\u201d \u0631\u0627\u0647\u200c\u0627\u0646\u062f\u0627\u0632\u06cc \u0634\u062f\u0647 \u0628\u0627\u0634\u062f.<\/span><\/div>\n
\u2022 \u0622\u0634\u0646\u0627\u06cc\u06cc \u0628\u0627 \u0633\u0627\u062e\u062a\u0627\u0631 \u062f\u0627\u06cc\u0631\u06a9\u062a\u0648\u0631\u06cc \u0627\u0633\u062a\u0627\u0646\u062f\u0627\u0631\u062f \u067e\u0631\u0648\u0698\u0647\u200c\u0647\u0627\u06cc \u062c\u0627\u0648\u0627. \u0628\u0631\u0627\u06cc \u0627\u0637\u0644\u0627\u0639\u0627\u062a \u0628\u06cc\u0634\u062a\u0631\u060c \u0628\u062e\u0634<\/span> \u201cIntroduction<\/span> to the Standard Directory Layout\u201d \u0631\u0627 \u062f\u0631 \u0645\u0633\u062a\u0646\u062f\u0627\u062a \u0631\u0633\u0645\u06cc Maven \u0645\u0634\u0627\u0647\u062f\u0647 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
\u2022 \u0646\u0635\u0628 Python 3 \u0631\u0648\u06cc Droplet \u06cc\u0627 \u0645\u0627\u0634\u06cc\u0646 \u0645\u062d\u0644\u06cc \u0634\u0645\u0627\u060c \u0628\u0647 \u0647\u0645\u0631\u0627\u0647 \u0631\u0627\u0647\u200c\u0627\u0646\u062f\u0627\u0632\u06cc \u06cc\u06a9 \u0645\u062d\u06cc\u0637 \u0645\u062c\u0627\u0632\u06cc \u062c\u062f\u06cc\u062f. \u062f\u0631 \u0635\u0648\u0631\u062a \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 \u0633\u0631\u0648\u0631 Ubuntu\u060c \u0628\u0647 \u0622\u0645\u0648\u0632\u0634<\/span> \u201cHow<\/span> To Install Python 3 and Set Up a Programming Environment on an Ubuntu Server\u201d \u0645\u0631\u0627\u062c\u0639\u0647 \u06a9\u0646\u06cc\u062f. \u0634\u0645\u0627 \u0641\u0642\u0637 \u0628\u0627\u06cc\u062f \u0645\u0631\u0627\u062d\u0644 \u06f1 \u0648 \u06f2 \u0631\u0627 \u062a\u06a9\u0645\u06cc\u0644 \u06a9\u0646\u06cc\u062f. \u062f\u0631 \u0627\u06cc\u0646 \u0622\u0645\u0648\u0632\u0634\u060c \u0645\u062d\u06cc\u0637 \u0645\u062c\u0627\u0632\u06cc \u0628\u0647 \u0639\u0646\u0648\u0627\u0646 ~\/venv \u062f\u0631 \u0646\u0638\u0631 \u06af\u0631\u0641\u062a\u0647 \u0645\u06cc\u200c\u0634\u0648\u062f.<\/span><\/div>\n
\u06af\u0627\u0645 1 – \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 Kafka AdminClient<\/span><\/div>\n
<\/div>\n
\u062f\u0631 \u0627\u06cc\u0646 \u06af\u0627\u0645\u060c \u0634\u0645\u0627 \u0628\u0627\u06cc\u062f \u06a9\u0644\u0627\u0633\u06cc \u0628\u0647 \u0646\u0627\u0645 AdminClientDemo.java \u0627\u06cc\u062c\u0627\u062f \u06a9\u0646\u06cc\u062f \u062a\u0627 \u0627\u0632 \u06a9\u0644\u0627\u0633 AdminClient \u0628\u0631\u0627\u06cc \u0645\u062f\u06cc\u0631\u06cc\u062a \u0628\u0631\u0646\u0627\u0645\u0647\u200c\u0646\u0648\u06cc\u0633\u06cc \u062e\u0648\u0634\u0647 Kafka \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
1. \u0627\u06cc\u062c\u0627\u062f \u06a9\u0644\u0627\u0633 AdminClientDemo.java<\/span><\/div>\n
<\/div>\n
\u0627\u0628\u062a\u062f\u0627 \u0628\u0647 \u062f\u0627\u06cc\u0631\u06a9\u062a\u0648\u0631\u06cc\u200c\u0627\u06cc \u06a9\u0647 \u067e\u0631\u0648\u0698\u0647 dokafka \u062f\u0631 \u0622\u0646 \u0642\u0631\u0627\u0631 \u062f\u0627\u0631\u062f \u0628\u0631\u0648\u06cc\u062f. \u0627\u06af\u0631 \u0627\u0632 \u0633\u0627\u062e\u062a\u0627\u0631 \u067e\u0631\u0648\u0698\u0647 \u0627\u0637\u0644\u0627\u0639 \u0646\u062f\u0627\u0631\u06cc\u062f\u060c \u0645\u0639\u0645\u0648\u0644\u0627\u064b \u067e\u0631\u0648\u0698\u0647 \u0628\u0627\u06cc\u062f \u0628\u0647 \u0627\u06cc\u0646 \u0634\u06a9\u0644 \u0628\u0627\u0634\u062f:<\/span><\/div>\n
dokafka\/<\/span><\/div>\n
\u251c\u2500\u2500 src\/<\/span><\/div>\n
\u2502 \u00a0 \u2514\u2500\u2500 main\/<\/span><\/div>\n
\u2502 \u00a0 \u00a0 \u00a0 \u2514\u2500\u2500 java\/<\/span><\/div>\n
\u2502 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u2514\u2500\u2500 com\/<\/span><\/div>\n
\u2502 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u2514\u2500\u2500 dokafka\/<\/span><\/div>\n
\u2502 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u2514\u2500\u2500 AdminClientDemo.java<\/span><\/div>\n
\u0627\u06a9\u0646\u0648\u0646 \u0641\u0627\u06cc\u0644 AdminClientDemo.java \u0631\u0627 \u0627\u06cc\u062c\u0627\u062f \u06a9\u0631\u062f\u0647 \u0648 \u0622\u0646 \u0631\u0627 \u0628\u0631\u0627\u06cc \u0648\u06cc\u0631\u0627\u06cc\u0634 \u0628\u0627\u0632 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
nano src\/main\/java\/com\/dokafka\/AdminClientDemo.java<\/span><\/div>\n
\u0633\u067e\u0633 \u06a9\u062f \u0632\u06cc\u0631 \u0631\u0627 \u0628\u0647 \u0641\u0627\u06cc\u0644 \u0627\u0636\u0627\u0641\u0647 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
package com.dokafka;<\/span><\/div>\n
<\/div>\n
import org.apache.kafka.clients.admin.*;<\/span><\/div>\n
import org.apache.kafka.common.Node;<\/span><\/div>\n
import org.slf4j.Logger;<\/span><\/div>\n
import org.slf4j.LoggerFactory;<\/span><\/div>\n
<\/div>\n
import java.util.*;<\/span><\/div>\n
<\/div>\n
public class AdminClientDemo {<\/span><\/div>\n
\u00a0 private static final Logger log = LoggerFactory.getLogger(AdminClientDemo.class);<\/span><\/div>\n
<\/div>\n
\u00a0 public static void main(String[] args) {<\/span><\/div>\n
\u00a0 \u00a0 String bootstrapServers =<\/span> “kafka1.your_domain:9092”;<\/span> \/\/ \u0622\u062f\u0631\u0633 \u0633\u0631\u0648\u0631 Kafka \u062e\u0648\u062f \u0631\u0627 \u062c\u0627\u06cc\u06af\u0632\u06cc\u0646 \u06a9\u0646\u06cc\u062f<\/span><\/div>\n
<\/div>\n
\u00a0 \u00a0 Properties properties = new Properties();<\/span><\/div>\n
\u00a0 \u00a0 properties.put(“bootstrap.servers”, bootstrapServers);<\/span><\/div>\n
\u00a0 \u00a0 final KafkaAdminClient client = AdminClient.create(properties);<\/span><\/div>\n
<\/div>\n
\u00a0 \u00a0 try {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 Collection<Node> nodes = client.describeCluster().nodes().get();<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 if<\/span> (nodes<\/span> == null)<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 log.info(“\u0628\u0647 \u0646\u0638\u0631 \u0645\u06cc\u200c\u0631\u0633\u062f \u0647\u06cc\u0686 \u06af\u0631\u0647\u200c\u0627\u06cc \u062f\u0631 \u062e\u0648\u0634\u0647 \u0648\u062c\u0648\u062f \u0646\u062f\u0627\u0631\u062f!”);<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 else<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 log.info(String.format(“\u062a\u0639\u062f\u0627\u062f \u06af\u0631\u0647\u200c\u0647\u0627: %s\\n”, nodes.size()));<\/span><\/div>\n
\u00a0 \u00a0 } catch<\/span> (Exception<\/span> e) {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 log.error(“\u062e\u0637\u0627\u06cc\u06cc \u0631\u062e \u062f\u0627\u062f”, e);<\/span><\/div>\n
\u00a0 \u00a0 }<\/span><\/div>\n
\u00a0 }<\/span><\/div>\n
}<\/span><\/div>\n
\u062a\u0648\u0636\u06cc\u062d \u06a9\u062f:<\/span><\/div>\n
\u2022 Logger: \u0627\u0632 LoggerFactory.getLogger() \u0628\u0631\u0627\u06cc \u0627\u06cc\u062c\u0627\u062f \u06cc\u06a9 \u0644\u0627\u06af\u0631 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0634\u062f\u0647 \u0627\u0633\u062a \u06a9\u0647 \u0645\u06cc\u200c\u062a\u0648\u0627\u0646 \u0627\u0632 \u0622\u0646 \u0628\u0631\u0627\u06cc \u062b\u0628\u062a \u067e\u06cc\u0627\u0645\u200c\u0647\u0627 \u062f\u0631 \u0633\u0637\u0648\u062d \u0645\u062e\u062a\u0644\u0641<\/span> (\u0627\u0637\u0644\u0627\u0639\u0627\u062a\u06cc\u060c<\/span> \u062e\u0637\u0627 \u0648 \u063a\u06cc\u0631\u0647) \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u06a9\u0631\u062f.<\/span><\/div>\n
\u2022 KafkaAdminClient: \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 KafkaAdminClient \u0645\u06cc\u200c\u062a\u0648\u0627\u0646 \u06a9\u0627\u0631\u0647\u0627\u06cc \u0645\u062f\u06cc\u0631\u06cc\u062a\u06cc \u0645\u062e\u062a\u0644\u0641\u06cc \u0631\u0627 \u0628\u0631 \u0631\u0648\u06cc \u062e\u0648\u0634\u0647 Kafka \u0627\u0646\u062c\u0627\u0645 \u062f\u0627\u062f<\/span> (\u0645\u0627\u0646\u0646\u062f<\/span> \u0634\u0631\u062d \u062e\u0648\u0634\u0647\u060c \u0627\u06cc\u062c\u0627\u062f \u06cc\u0627 \u062d\u0630\u0641 \u0645\u0648\u0636\u0648\u0639\u0627\u062a \u0648 \u063a\u06cc\u0631\u0647).<\/span><\/div>\n
\u2022 bootstrap.servers: \u0622\u062f\u0631\u0633 \u062e\u0648\u0634\u0647 Kafka \u0631\u0627 \u0645\u0634\u062e\u0635 \u0645\u06cc\u200c\u06a9\u0646\u062f. \u0628\u0647 \u06cc\u0627\u062f \u062f\u0627\u0634\u062a\u0647 \u0628\u0627\u0634\u06cc\u062f \u06a9\u0647 kafka1.your_domain:9092 \u0631\u0627 \u0628\u0627 \u0622\u062f\u0631\u0633 \u0648\u0627\u0642\u0639\u06cc \u0633\u0631\u0648\u0631 Kafka \u062e\u0648\u062f \u062c\u0627\u06cc\u06af\u0632\u06cc\u0646 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
2. \u0627\u06cc\u062c\u0627\u062f \u0627\u0633\u06a9\u0631\u06cc\u067e\u062a run-adminclient.sh<\/span><\/div>\n
<\/div>\n
\u062d\u0627\u0644\u0627 \u0628\u0627\u06cc\u062f \u06cc\u06a9 \u0627\u0633\u06a9\u0631\u06cc\u067e\u062a \u0628\u0647 \u0646\u0627\u0645 run-adminclient.sh \u0628\u0631\u0627\u06cc \u06a9\u0627\u0645\u067e\u0627\u06cc\u0644 \u0648 \u0627\u062c\u0631\u0627\u06cc \u06a9\u0644\u0627\u0633 AdminClientDemo \u0628\u0633\u0627\u0632\u06cc\u062f. \u0627\u06cc\u0646 \u0627\u0633\u06a9\u0631\u06cc\u067e\u062a \u0631\u0627 \u0627\u06cc\u062c\u0627\u062f \u06a9\u0631\u062f\u0647 \u0648 \u0628\u0631\u0627\u06cc \u0648\u06cc\u0631\u0627\u06cc\u0634 \u0628\u0627\u0632 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
nano run-adminclient.sh<\/span><\/div>\n
\u0633\u067e\u0633 \u06a9\u062f \u0632\u06cc\u0631 \u0631\u0627 \u0628\u0647 \u0627\u0633\u06a9\u0631\u06cc\u067e\u062a \u0627\u0636\u0627\u0641\u0647 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
#!\/bin\/bash<\/span><\/div>\n
mvn clean<\/span><\/div>\n
mvn package<\/span><\/div>\n
java<\/span> -cp<\/span> target\/dokafka-1.0-SNAPSHOT.jar:target\/lib\/* com.dokafka.AdminClientDemo<\/span><\/div>\n
\u062a\u0648\u0636\u06cc\u062d \u06a9\u062f \u0627\u0633\u06a9\u0631\u06cc\u067e\u062a:<\/span><\/div>\n
\u2022 mvn clean: \u0627\u06cc\u0646 \u062f\u0633\u062a\u0648\u0631 \u0628\u0631\u0627\u06cc \u067e\u0627\u06a9\u0633\u0627\u0632\u06cc \u067e\u0631\u0648\u0698\u0647 \u0627\u0632 \u0641\u0627\u06cc\u0644\u200c\u0647\u0627\u06cc \u06a9\u0627\u0645\u067e\u0627\u06cc\u0644\u200c\u0634\u062f\u0647 \u0642\u0628\u0644\u06cc \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0645\u06cc\u200c\u0634\u0648\u062f.<\/span><\/div>\n
\u2022 mvn package: \u0627\u06cc\u0646 \u062f\u0633\u062a\u0648\u0631 \u0628\u0631\u0627\u06cc \u06a9\u0627\u0645\u067e\u0627\u06cc\u0644 \u0648 \u0628\u0633\u062a\u0647\u200c\u0628\u0646\u062f\u06cc \u067e\u0631\u0648\u0698\u0647 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0645\u06cc\u200c\u0634\u0648\u062f.<\/span><\/div>\n
\u2022 java<\/span> -cp:<\/span> \u0627\u06cc\u0646 \u062f\u0633\u062a\u0648\u0631 \u0628\u0631\u0627\u06cc \u0627\u062c\u0631\u0627\u06cc \u06a9\u0644\u0627\u0633 AdminClientDemo \u0627\u0633\u062a \u06a9\u0647 \u062f\u0631 \u0628\u0633\u062a\u0647 dokafka \u0642\u0631\u0627\u0631 \u062f\u0627\u0631\u062f.<\/span><\/div>\n
<\/div>\n
3. \u0627\u0639\u0637\u0627\u06cc \u0645\u062c\u0648\u0632 \u0627\u062c\u0631\u0627\u06cc\u06cc \u0628\u0647 \u0627\u0633\u06a9\u0631\u06cc\u067e\u062a<\/span><\/div>\n
<\/div>\n
\u0628\u0639\u062f \u0627\u0632 \u0630\u062e\u06cc\u0631\u0647 \u0648 \u0628\u0633\u062a\u0646 \u0641\u0627\u06cc\u0644\u060c \u0627\u0633\u06a9\u0631\u06cc\u067e\u062a \u0631\u0627 \u0642\u0627\u0628\u0644 \u0627\u062c\u0631\u0627 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
chmod +x run-adminclient.sh<\/span><\/div>\n
4. \u0627\u062c\u0631\u0627\u06cc \u0627\u0633\u06a9\u0631\u06cc\u067e\u062a<\/span><\/div>\n
<\/div>\n
\u062f\u0631 \u0646\u0647\u0627\u06cc\u062a\u060c \u0627\u0633\u06a9\u0631\u06cc\u067e\u062a \u0631\u0627 \u0627\u062c\u0631\u0627 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
.\/run-adminclient.sh<\/span><\/div>\n
\u062e\u0631\u0648\u062c\u06cc<\/span><\/div>\n
\u2026<\/span><\/div>\n
[main] INFO com.dokafka.AdminClientDemo – \u062a\u0639\u062f\u0627\u062f \u06af\u0631\u0647\u200c\u0647\u0627: 3<\/span><\/div>\n
<\/div>\n
AdminClientDemo \u0628\u0627 \u0645\u0648\u0641\u0642\u06cc\u062a \u0628\u0647 \u0646\u0635\u0628 Kafka \u0634\u0645\u0627 \u0645\u062a\u0635\u0644 \u0634\u062f\u0647 \u0648 \u062a\u0639\u062f\u0627\u062f \u06af\u0631\u0647\u200c\u0647\u0627 \u0631\u0627 \u0628\u0627\u0632\u06cc\u0627\u0628\u06cc \u06a9\u0631\u062f\u0647 \u0627\u0633\u062a.<\/span><\/div>\n
<\/div>\n
\u0627\u06cc\u062c\u0627\u062f \u0648 \u0641\u0647\u0631\u0633\u062a \u06a9\u0631\u062f\u0646 \u0645\u0648\u0636\u0648\u0639\u0627\u062a<\/span><\/div>\n
KafkaAdminClient \u0645\u062a\u062f\u0647\u0627\u06cc createTopics() \u0648 listTopics() \u0631\u0627 \u0641\u0631\u0627\u0647\u0645 \u0645\u06cc\u200c\u06a9\u0646\u062f\u060c \u06a9\u0647 \u062d\u0627\u0644\u0627 \u0634\u0645\u0627 \u0627\u0632 \u0622\u0646\u200c\u0647\u0627 \u0628\u0631\u0627\u06cc \u0627\u06cc\u062c\u0627\u062f \u06cc\u06a9 \u0645\u0648\u0636\u0648\u0639 \u0648 \u0633\u067e\u0633 \u0641\u0647\u0631\u0633\u062a \u06a9\u0631\u062f\u0646 \u062a\u0645\u0627\u0645 \u0645\u0648\u0636\u0648\u0639\u0627\u062a \u0645\u0648\u062c\u0648\u062f \u062f\u0631 \u06a9\u0644\u0627\u0633\u062a\u0631 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u062e\u0648\u0627\u0647\u06cc\u062f \u06a9\u0631\u062f.<\/span><\/div>\n
<\/div>\n
\u0627\u0628\u062a\u062f\u0627 \u0628\u0631\u0627\u06cc \u0648\u06cc\u0631\u0627\u06cc\u0634 AdminClientDemo \u0622\u0646 \u0631\u0627 \u0628\u0627\u0632 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
nano src\/main\/java\/com\/dokafka\/AdminClientDemo.java<\/span><\/div>\n
<\/div>\n
\u06a9\u062f \u0631\u0627 \u0628\u0647 \u0627\u06cc\u0646 \u0634\u06a9\u0644 \u062a\u063a\u06cc\u06cc\u0631 \u062f\u0647\u06cc\u062f:<\/span><\/div>\n
nano src\/main\/java\/com\/dokafka\/AdminClientDemo.java<\/span><\/div>\n
\u2026<\/span><\/div>\n
try {<\/span><\/div>\n
NewTopic newTopic = new NewTopic(\u201cnewTopic\u201d, 1,<\/span> (short)<\/span> 1);<\/span><\/div>\n
CreateTopicsResult result = client.createTopics(<\/span><\/div>\n
Collections.singleton(newTopic)<\/span><\/div>\n
);<\/span><\/div>\n
result.all().get();<\/span><\/div>\n
\u00a0 ListTopicsOptions options = new ListTopicsOptions();<\/span><\/div>\n
\u00a0 options.listInternal(true);<\/span><\/div>\n
\u00a0 Collection<TopicListing> topics = client.listTopics(options).listings().get();<\/span><\/div>\n
\u00a0 for<\/span> (TopicListing<\/span> topic: topics) {<\/span><\/div>\n
\u00a0 \u00a0 log.info(“Topic: ” + topic.name());<\/span><\/div>\n
\u00a0 }<\/span><\/div>\n
} catch<\/span> (Exception<\/span> e) {<\/span><\/div>\n
\u00a0 log.error(“An error occurred”, e);<\/span><\/div>\n
}<\/span><\/div>\n
\u2026<\/span><\/div>\n
\u062f\u0631 \u0627\u0628\u062a\u062f\u0627 \u06cc\u06a9 \u0646\u0645\u0648\u0646\u0647 \u0627\u0632 NewTopic \u0627\u06cc\u062c\u0627\u062f \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f\u060c \u06a9\u0647 \u0645\u0648\u0636\u0648\u0639\u06cc \u0627\u0633\u062a \u06a9\u0647 \u0628\u0627\u06cc\u062f \u062f\u0631 \u06a9\u0644\u0627\u0633\u062a\u0631 \u0627\u06cc\u062c\u0627\u062f \u0634\u0648\u062f. \u0646\u0627\u0645 \u0622\u0646<\/span> (\u201cnewTopic\u201d)<\/span> \u0648 \u062a\u0639\u062f\u0627\u062f \u0628\u062e\u0634\u200c\u0647\u0627 \u0648 \u0646\u0633\u062e\u0647\u200c\u0647\u0627 \u0631\u0627 \u0648\u0627\u0631\u062f \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f \u06a9\u0647 \u0628\u0627\u06cc\u062f \u0628\u0647 \u0646\u0648\u0639 short \u062a\u0628\u062f\u06cc\u0644 \u0634\u0648\u0646\u062f. \u0645\u062a\u062f createTopics() \u06cc\u06a9 \u0645\u062c\u0645\u0648\u0639\u0647 \u0627\u0632 \u0646\u0645\u0648\u0646\u0647\u200c\u0647\u0627\u06cc NewTopic \u0631\u0627 \u0645\u06cc\u200c\u067e\u0630\u06cc\u0631\u062f\u060c \u0628\u0646\u0627\u0628\u0631\u0627\u06cc\u0646 \u0634\u0645\u0627 \u06cc\u06a9 \u0644\u06cc\u0633\u062a \u0628\u0627 \u06cc\u06a9 \u0639\u0646\u0635\u0631 \u06a9\u0647 \u0641\u0642\u0637 newTopic \u0631\u0627 \u0634\u0627\u0645\u0644 \u0645\u06cc\u200c\u0634\u0648\u062f\u060c \u0645\u06cc\u200c\u0633\u0627\u0632\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
\u0686\u0648\u0646 \u0627\u06cc\u0646 \u0645\u062a\u062f \u0628\u0647 \u0635\u0648\u0631\u062a \u063a\u06cc\u0631 \u0647\u0645\u0632\u0645\u0627\u0646 \u0627\u0633\u062a\u060c \u062c\u0631\u06cc\u0627\u0646 \u0627\u062c\u0631\u0627 \u0628\u0644\u0627\u0641\u0627\u0635\u0644\u0647 \u067e\u0633 \u0627\u0632 \u0641\u0631\u0627\u062e\u0648\u0627\u0646\u06cc \u0628\u0647 main() \u0628\u0627\u0632 \u062e\u0648\u0627\u0647\u062f \u06af\u0634\u062a\u060c \u062f\u0631 \u062d\u0627\u0644\u06cc \u06a9\u0647 \u062f\u0631 \u067e\u0633\u200c\u0632\u0645\u06cc\u0646\u0647 \u0627\u062f\u0627\u0645\u0647 \u0645\u06cc\u200c\u062f\u0647\u062f. \u0627\u0632 \u0622\u0646\u062c\u0627\u06cc\u06cc \u06a9\u0647 \u0634\u0645\u0627 \u0642\u0635\u062f \u062f\u0627\u0631\u06cc\u062f \u0645\u0648\u0636\u0648\u0639\u0627\u062a \u0631\u0627 \u062f\u0631 \u0627\u062f\u0627\u0645\u0647 \u0641\u0647\u0631\u0633\u062a \u06a9\u0646\u06cc\u062f\u060c \u0628\u0627\u06cc\u062f \u0645\u0646\u062a\u0638\u0631 \u0628\u0645\u0627\u0646\u06cc\u062f \u062a\u0627 \u0627\u06cc\u0646 \u0639\u0645\u0644\u06cc\u0627\u062a \u0628\u0627 result.all().get() \u062a\u06a9\u0645\u06cc\u0644 \u0634\u0648\u062f. result \u0634\u0627\u0645\u0644 \u06cc\u06a9 \u0644\u06cc\u0633\u062a \u0627\u0632 \u0645\u0648\u0636\u0648\u0639\u0627\u062a \u0627\u06cc\u062c\u0627\u062f \u0634\u062f\u0647 \u0627\u0633\u062a \u0648 \u0628\u0631\u0627\u06cc \u062f\u0631\u06cc\u0627\u0641\u062a \u0647\u0645\u0647\u200c\u06cc \u0622\u0646\u200c\u0647\u0627 \u0628\u0627\u06cc\u062f \u0639\u0645\u0644\u06cc\u0627\u062a \u062a\u06a9\u0645\u06cc\u0644 \u0634\u0648\u062f.<\/span><\/div>\n
<\/div>\n
\u0633\u067e\u0633 \u06cc\u06a9 \u0646\u0645\u0648\u0646\u0647 \u0627\u0632 ListTopicsOptions \u0631\u0627 \u0645\u06cc\u200c\u0633\u0627\u0632\u06cc\u062f \u06a9\u0647 \u067e\u06cc\u06a9\u0631\u0628\u0646\u062f\u06cc \u0628\u0631\u0627\u06cc \u0641\u0631\u0627\u06cc\u0646\u062f \u0628\u0627\u0632\u06cc\u0627\u0628\u06cc \u0645\u0648\u0636\u0648\u0639\u0627\u062a \u0631\u0627 \u0646\u06af\u0647 \u0645\u06cc\u200c\u062f\u0627\u0631\u062f. \u0645\u062a\u062f listInternal() \u0631\u0627 \u0635\u062f\u0627 \u0645\u06cc\u200c\u0632\u0646\u06cc\u062f \u0648 true \u0631\u0627 \u0628\u0647 \u0622\u0646 \u0645\u06cc\u200c\u062f\u0647\u06cc\u062f \u062a\u0627 \u0645\u0648\u0636\u0648\u0639\u0627\u062a\u06cc \u06a9\u0647 Kafka \u0622\u0646\u200c\u0647\u0627 \u0631\u0627 \u0628\u0647 \u0639\u0646\u0648\u0627\u0646 \u0645\u0648\u0627\u0631\u062f \u062f\u0627\u062e\u0644\u06cc \u062f\u0631 \u0646\u0638\u0631 \u0645\u06cc\u200c\u06af\u06cc\u0631\u062f \u0646\u06cc\u0632 \u062f\u0631\u06cc\u0627\u0641\u062a \u0634\u0648\u0646\u062f. \u0633\u067e\u0633 \u0622\u0646 \u0631\u0627 \u0628\u0647 client.listTopics() \u0645\u06cc\u200c\u062f\u0647\u06cc\u062f \u0648 \u0641\u0647\u0631\u0633\u062a\u200c\u0647\u0627 \u0631\u0627 \u0627\u0632 \u0637\u0631\u06cc\u0642 listings() \u0628\u0627\u0632\u06cc\u0627\u0628\u06cc \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f\u060c \u06a9\u0647 \u062f\u0631 \u0622\u0646 \u062d\u0644\u0642\u0647 \u0645\u06cc\u200c\u0632\u0646\u06cc\u062f \u0648 \u0646\u0627\u0645\u200c\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639\u0627\u062a \u0631\u0627 \u062b\u0628\u062a \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
\u067e\u0633 \u0627\u0632 \u067e\u0627\u06cc\u0627\u0646 \u06a9\u0627\u0631\u060c \u0641\u0627\u06cc\u0644 \u0631\u0627 \u0630\u062e\u06cc\u0631\u0647 \u06a9\u0631\u062f\u0647 \u0648 \u0622\u0646 \u0631\u0627 \u0628\u0628\u0646\u062f\u06cc\u062f\u060c \u0633\u067e\u0633 \u0627\u0633\u06a9\u0631\u06cc\u067e\u062a \u0631\u0627 \u0627\u062c\u0631\u0627 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
.\/run-adminclient.sh<\/span><\/div>\n
<\/div>\n
\u062a\u0645\u0627\u0645 \u0645\u0648\u0636\u0648\u0639\u0627\u062a \u0645\u0648\u062c\u0648\u062f \u062f\u0631 \u06a9\u0644\u0627\u0633\u062a\u0631 \u062f\u0631 \u0627\u0646\u062a\u0647\u0627\u06cc \u062e\u0631\u0648\u062c\u06cc \u0641\u0647\u0631\u0633\u062a \u062e\u0648\u0627\u0647\u0646\u062f \u0634\u062f:<\/span><\/div>\n
<\/div>\n
\u062e\u0631\u0648\u062c\u06cc<\/span><\/div>\n
\u2026<\/span><\/div>\n
[main] INFO com.dokafka.AdminClientDemo – Topic: newTopic<\/span><\/div>\n
[main] INFO com.dokafka.AdminClientDemo – Topic: java_demo<\/span><\/div>\n
\u062d\u0630\u0641 \u0645\u0648\u0636\u0648\u0639\u0627\u062a<\/span><\/div>\n
\u0628\u0631\u0627\u06cc \u062d\u0630\u0641 \u06cc\u06a9 \u0645\u0648\u0636\u0648\u0639<\/span> (\u06cc\u0627<\/span> \u0686\u0646\u062f\u06cc\u0646 \u0645\u0648\u0636\u0648\u0639)\u060c \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u06cc\u062f \u0627\u0632 \u0645\u062a\u062f deleteTopics() \u062f\u0631 KafkaAdminClient \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u06a9\u0646\u06cc\u062f. \u062d\u0627\u0644\u0627 \u0627\u0632 \u0622\u0646 \u0628\u0631\u0627\u06cc \u062d\u0630\u0641 newTopic \u06a9\u0647 \u0628\u0647 \u062a\u0627\u0632\u06af\u06cc \u0627\u06cc\u062c\u0627\u062f \u06a9\u0631\u062f\u0647\u200c\u0627\u06cc\u062f \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u062e\u0648\u0627\u0647\u06cc\u062f \u06a9\u0631\u062f. \u0628\u0631\u0627\u06cc \u0648\u06cc\u0631\u0627\u06cc\u0634 AdminClientDemo \u0622\u0646 \u0631\u0627 \u0628\u0627\u0632 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
nano src\/main\/java\/com\/dokafka\/AdminClientDemo.java<\/span><\/div>\n
<\/div>\n
\u06a9\u062f \u0645\u0631\u0628\u0648\u0637 \u0628\u0647 \u0627\u06cc\u062c\u0627\u062f \u0645\u0648\u0636\u0648\u0639 \u0631\u0627 \u0628\u0627 \u062e\u0637\u0648\u0637 \u0628\u0631\u062c\u0633\u062a\u0647\u200c\u0634\u062f\u0647 \u062c\u0627\u06cc\u06af\u0632\u06cc\u0646 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
nano src\/main\/java\/com\/dokafka\/AdminClientDemo.java<\/span><\/div>\n
\u2026<\/span><\/div>\n
DeleteTopicsResult deleted = client.deleteTopics(Collections.singleton(\u201cnewTopic\u201d));<\/span><\/div>\n
deleted.all().get();<\/span><\/div>\n
log.info(\u201c\u0645\u0648\u0636\u0648\u0639 newTopic \u062d\u0630\u0641 \u0634\u062f!\u201d);<\/span><\/div>\n
\u00a0 ListTopicsOptions options = new ListTopicsOptions();<\/span><\/div>\n
\u00a0 options.listInternal(true);<\/span><\/div>\n
\u00a0 Collection<TopicListing> topics = client.listTopics(options).listings().get();<\/span><\/div>\n
\u00a0 for<\/span> (TopicListing<\/span> topic: topics) {<\/span><\/div>\n
\u00a0 \u00a0 log.info(“\u0645\u0648\u0636\u0648\u0639: ” + topic.name());<\/span><\/div>\n
\u00a0 }<\/span><\/div>\n
\u2026<\/span><\/div>\n
\u062f\u0631 \u0627\u06cc\u0646\u062c\u0627\u060c \u0634\u0645\u0627 \u06cc\u06a9 \u0645\u062c\u0645\u0648\u0639\u0647 \u0627\u0632 \u0631\u0634\u062a\u0647\u200c\u0647\u0627 \u06a9\u0647 \u0646\u0645\u0627\u06cc\u0627\u0646\u06af\u0631 \u0646\u0627\u0645\u200c\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639\u0627\u062a \u0647\u0633\u062a\u0646\u062f \u0631\u0627 \u0628\u0647 client.deleteTopics() \u0645\u06cc\u200c\u062f\u0647\u06cc\u062f. \u0633\u067e\u0633 \u0645\u0646\u062a\u0638\u0631 \u0645\u06cc\u200c\u0645\u0627\u0646\u06cc\u062f \u062a\u0627 \u0641\u0631\u0627\u06cc\u0646\u062f \u062a\u06a9\u0645\u06cc\u0644 \u0634\u0648\u062f \u0628\u0627 \u06af\u0631\u0641\u062a\u0646 deleted.all() \u06a9\u0647 \u0641\u0642\u0637 \u0632\u0645\u0627\u0646\u06cc \u0628\u0631\u0645\u06cc\u200c\u06af\u0631\u062f\u062f \u06a9\u0647 \u062a\u0645\u0627\u0645 \u0645\u0648\u0636\u0648\u0639\u0627\u062a \u067e\u0631\u062f\u0627\u0632\u0634 \u0634\u062f\u0647 \u0628\u0627\u0634\u0646\u062f. \u067e\u0633 \u0627\u0632 \u067e\u0627\u06cc\u0627\u0646 \u06a9\u0627\u0631\u060c \u0641\u0627\u06cc\u0644 \u0631\u0627 \u0630\u062e\u06cc\u0631\u0647 \u06a9\u0631\u062f\u0647 \u0648 \u0622\u0646 \u0631\u0627 \u0628\u0628\u0646\u062f\u06cc\u062f\u060c \u0633\u067e\u0633 \u0627\u0633\u06a9\u0631\u06cc\u067e\u062a run-adminclient.sh \u0631\u0627 \u0627\u062c\u0631\u0627 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
.\/run-adminclient.sh<\/span><\/div>\n
<\/div>\n
\u062e\u0648\u0627\u0647\u06cc\u062f \u062f\u06cc\u062f \u06a9\u0647 \u0645\u0648\u0636\u0648\u0639 \u062c\u062f\u06cc\u062f \u062f\u0631 \u0641\u0647\u0631\u0633\u062a \u0645\u0648\u0636\u0648\u0639\u0627\u062a \u0645\u0648\u062c\u0648\u062f \u0646\u06cc\u0633\u062a:<\/span><\/div>\n
<\/div>\n
\u062e\u0631\u0648\u062c\u06cc<\/span><\/div>\n
[main] INFO com.dokafka.AdminClientDemo – \u0645\u0648\u0636\u0648\u0639 newTopic \u062d\u0630\u0641 \u0634\u062f!<\/span><\/div>\n
[main] INFO com.dokafka.AdminClientDemo – \u0645\u0648\u0636\u0648\u0639: java_demo<\/span><\/div>\n
<\/div>\n
\u062f\u0631 \u0627\u06cc\u0646 \u0645\u0631\u062d\u0644\u0647\u060c \u0634\u0645\u0627 \u0627\u0632 KafkaAdminClient \u0628\u0631\u0627\u06cc \u062f\u0633\u062a\u0631\u0633\u06cc \u0628\u0647 \u06a9\u0644\u0627\u0633\u062a\u0631 \u062e\u0648\u062f \u0648 \u0628\u0627\u0632\u06cc\u0627\u0628\u06cc \u0627\u0637\u0644\u0627\u0639\u0627\u062a \u0622\u0646 \u0628\u0647 \u0635\u0648\u0631\u062a \u0628\u0631\u0646\u0627\u0645\u0647\u200c\u0646\u0648\u06cc\u0633\u06cc \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u06a9\u0631\u062f\u0647\u200c\u0627\u06cc\u062f. \u0647\u0645\u0686\u0646\u06cc\u0646 \u0646\u062d\u0648\u0647 \u0641\u0647\u0631\u0633\u062a \u06a9\u0631\u062f\u0646\u060c \u0627\u06cc\u062c\u0627\u062f \u0648 \u062d\u0630\u0641 \u0645\u0648\u0636\u0648\u0639\u0627\u062a \u062f\u0631 \u06a9\u0644\u0627\u0633\u062a\u0631 \u0631\u0627 \u0645\u0634\u0627\u0647\u062f\u0647 \u06a9\u0631\u062f\u0647\u200c\u0627\u06cc\u062f. \u062d\u0627\u0644\u0627 \u062e\u0648\u0627\u0647\u06cc\u062f \u0622\u0645\u0648\u062e\u062a \u06a9\u0647 \u0686\u06af\u0648\u0646\u0647 \u0627\u0632 \u0627\u0628\u0632\u0627\u0631 \u062e\u0637 \u0641\u0631\u0645\u0627\u0646 kcat \u0628\u0631\u0627\u06cc \u062f\u0633\u062a\u0631\u0633\u06cc \u0628\u0647 \u06a9\u0644\u0627\u0633\u062a\u0631 \u062e\u0648\u062f \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
\u0645\u0631\u062d\u0644\u0647 2 – \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 kcat \u0628\u0631\u0627\u06cc \u0645\u062f\u06cc\u0631\u06cc\u062a \u06a9\u0644\u0627\u0633\u062a\u0631<\/span><\/div>\n
\u062f\u0631 \u0627\u06cc\u0646 \u0645\u0631\u062d\u0644\u0647\u060c \u0634\u0645\u0627 \u06cc\u0627\u062f \u062e\u0648\u0627\u0647\u06cc\u062f \u06af\u0631\u0641\u062a \u06a9\u0647 \u0686\u06af\u0648\u0646\u0647 kcat\u060c \u0627\u0628\u0632\u0627\u0631\u06cc \u062e\u0637 \u0641\u0631\u0645\u0627\u0646 \u0628\u0631\u0627\u06cc \u062f\u0633\u062a\u0631\u0633\u06cc \u0648 \u067e\u06cc\u06a9\u0631\u0628\u0646\u062f\u06cc \u06a9\u0644\u0627\u0633\u062a\u0631\u0647\u0627\u06cc Kafka \u0631\u0627 \u062f\u0627\u0646\u0644\u0648\u062f \u0648 \u0646\u0635\u0628 \u06a9\u0646\u06cc\u062f\u060c \u0628\u062f\u0648\u0646 \u0646\u06cc\u0627\u0632 \u0628\u0647 \u0648\u0627\u0628\u0633\u062a\u06af\u06cc \u0628\u0647 Java.<\/span><\/div>\n
<\/div>\n
\u0627\u0628\u062a\u062f\u0627 \u0628\u0627\u06cc\u062f \u0628\u0633\u062a\u0647 \u0645\u0646\u0627\u0633\u0628 \u0628\u0631\u0627\u06cc \u0633\u06cc\u0633\u062a\u0645\u200c\u0639\u0627\u0645\u0644 \u062e\u0648\u062f \u0631\u0627 \u0646\u0635\u0628 \u06a9\u0646\u06cc\u062f. \u0627\u06af\u0631 \u0627\u0632 MacOS \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f\u060c \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u06cc\u062f kcat \u0631\u0627 \u0628\u0627 Brew \u062f\u0627\u0646\u0644\u0648\u062f \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
brew install kcat<\/span><\/div>\n
<\/div>\n
\u062f\u0631 \u0633\u06cc\u0633\u062a\u0645\u200c\u0647\u0627\u06cc Debian \u0648 Ubuntu\u060c \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u06cc\u062f \u0622\u0646 \u0631\u0627 \u0628\u0647\u200c\u0637\u0648\u0631 \u0645\u0639\u0645\u0648\u0644 \u0627\u0632 \u0637\u0631\u06cc\u0642 apt \u0646\u0635\u0628 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
sudo apt install kafkacat<\/span><\/div>\n
<\/div>\n
kafkacat \u0646\u0627\u0645 \u0642\u062f\u06cc\u0645\u06cc \u0628\u0631\u0627\u06cc kcat \u0627\u0633\u062a\u060c \u0627\u0645\u0627 \u0628\u0631\u0627\u06cc \u0633\u0627\u0632\u06af\u0627\u0631\u06cc \u062f\u0631 \u0645\u062f\u06cc\u0631 \u0628\u0633\u062a\u0647 \u0646\u06af\u0647\u200c\u062f\u0627\u0634\u062a\u0647 \u0634\u062f\u0647 \u0627\u0633\u062a. \u0628\u0631\u0627\u06cc \u062f\u0633\u062a\u0648\u0631\u0627\u0644\u0639\u0645\u0644\u200c\u0647\u0627\u06cc \u0646\u0635\u0628 \u062f\u0631 \u062a\u0648\u0632\u06cc\u0639\u200c\u0647\u0627\u06cc \u062f\u06cc\u06af\u0631\u060c \u0628\u0647 \u0645\u0633\u062a\u0646\u062f\u0627\u062a \u0631\u0633\u0645\u06cc \u0645\u0631\u0627\u062c\u0639\u0647 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
\u062a\u0648\u0644\u06cc\u062f \u0648 \u0645\u0635\u0631\u0641 \u067e\u06cc\u0627\u0645\u200c\u0647\u0627<\/span><\/div>\n
\u06cc\u06a9\u06cc \u0627\u0632 \u0639\u0645\u0644\u06cc\u0627\u062a\u200c\u0647\u0627\u06cc \u067e\u0627\u06cc\u0647\u200c\u0627\u06cc \u06a9\u0647 \u0627\u0633\u06a9\u0631\u06cc\u067e\u062a\u200c\u0647\u0627\u06cc \u0647\u0645\u0631\u0627\u0647 Kafka \u0627\u062c\u0627\u0632\u0647 \u0645\u06cc\u200c\u062f\u0647\u0646\u062f\u060c \u067e\u062e\u0634 \u062f\u0627\u062f\u0647\u200c\u0647\u0627 \u0627\u0632 \u06cc\u06a9 \u0645\u0648\u0636\u0648\u0639 \u0627\u0633\u062a. \u0628\u0627 kcat\u060c \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u06cc\u062f \u0627\u0632 \u0686\u0646\u062f\u06cc\u0646 \u0645\u0648\u0636\u0648\u0639 \u0628\u0647\u200c\u0637\u0648\u0631 \u0647\u0645\u200c\u0632\u0645\u0627\u0646 \u067e\u062e\u0634 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
kcat<\/span> -b<\/span> your_broker_address:9092 first_topic second_topic \u2026<\/span><\/div>\n
<\/div>\n
\u0627\u062c\u0631\u0627\u06cc \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u067e\u06cc\u0627\u0645\u200c\u0647\u0627 \u0631\u0627 \u0627\u0632 java_demotopic \u062f\u0631 \u06a9\u0646\u0633\u0648\u0644 \u067e\u062e\u0634 \u0645\u06cc\u200c\u06a9\u0646\u062f:<\/span><\/div>\n
kcat<\/span> -b<\/span> kafka1.your_domain:9092 java_demo<\/span><\/div>\n
<\/div>\n
\u0627\u0633\u06a9\u0631\u06cc\u067e\u062a Kafka-console-consumer.sh \u0647\u0645\u0686\u0646\u06cc\u0646 \u0628\u0647 \u0634\u0645\u0627 \u0627\u06cc\u0646 \u0627\u0645\u06a9\u0627\u0646 \u0631\u0627 \u0645\u06cc\u200c\u062f\u0647\u062f \u06a9\u0647 \u062a\u0645\u0627\u0645 \u067e\u06cc\u0627\u0645\u200c\u0647\u0627\u06cc \u0645\u0648\u062c\u0648\u062f \u062f\u0631 \u06cc\u06a9 \u0645\u0648\u0636\u0648\u0639 \u0631\u0627 \u0627\u0632 \u0627\u0628\u062a\u062f\u0627 \u0628\u062e\u0648\u0627\u0646\u06cc\u062f. \u0628\u0631\u0627\u06cc \u062f\u0633\u062a\u06cc\u0627\u0628\u06cc \u0628\u0647 \u0647\u0645\u06cc\u0646 \u0647\u062f\u0641 \u0628\u0627 kcat\u060c \u0628\u0627\u06cc\u062f<\/span> -t<\/span> \u0631\u0627 \u0648\u0627\u0631\u062f \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
kcat<\/span> -b<\/span> kafka1.your_domain:9092<\/span> -t<\/span> java_demo<\/span><\/div>\n
<\/div>\n
\u062e\u0631\u0648\u062c\u06cc \u0634\u0627\u0645\u0644 \u067e\u06cc\u0627\u0645\u200c\u0647\u0627\u06cc\u06cc \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f \u06a9\u0647 \u0634\u0645\u0627 \u062f\u0631 \u0628\u062e\u0634 \u067e\u06cc\u0634\u200c\u0646\u06cc\u0627\u0632\u0647\u0627 \u062a\u0648\u0644\u06cc\u062f \u06a9\u0631\u062f\u0647\u200c\u0627\u06cc\u062f:<\/span><\/div>\n
\u062e\u0631\u0648\u062c\u06cc<\/span><\/div>\n
% \u0627\u0646\u062a\u062e\u0627\u0628 \u062e\u0648\u062f\u06a9\u0627\u0631 \u062d\u0627\u0644\u062a \u0645\u0635\u0631\u0641\u200c\u06a9\u0646\u0646\u062f\u0647<\/span> (\u0628\u0631\u0627\u06cc<\/span> \u0644\u063a\u0648 \u0627\u0632<\/span> -P<\/span> \u06cc\u0627<\/span> -C<\/span> \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u06a9\u0646\u06cc\u062f)<\/span><\/div>\n
% \u0628\u0647 \u0627\u0646\u062a\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639 java_demo<\/span> [1]<\/span> \u062f\u0631 \u0627\u0641\u0633\u062a 0 \u0631\u0633\u06cc\u062f<\/span><\/div>\n
% \u0628\u0647 \u0627\u0646\u062a\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639 java_demo<\/span> [2]<\/span> \u062f\u0631 \u0627\u0641\u0633\u062a 0 \u0631\u0633\u06cc\u062f<\/span><\/div>\n
Hello World!<\/span><\/div>\n
% \u0628\u0647 \u0627\u0646\u062a\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639 java_demo<\/span> [0]<\/span> \u062f\u0631 \u0627\u0641\u0633\u062a 0 \u0631\u0633\u06cc\u062f<\/span><\/div>\n
% \u0628\u0647 \u0627\u0646\u062a\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639 java_demo<\/span> [3]<\/span> \u062f\u0631 \u0627\u0641\u0633\u062a 0 \u0631\u0633\u06cc\u062f<\/span><\/div>\n
% \u0628\u0647 \u0627\u0646\u062a\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639 java_demo<\/span> [4]<\/span> \u062f\u0631 \u0627\u0641\u0633\u062a 1 \u0631\u0633\u06cc\u062f<\/span><\/div>\n
% \u0628\u0647 \u0627\u0646\u062a\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639 java_demo<\/span> [5]<\/span> \u062f\u0631 \u0627\u0641\u0633\u062a 0 \u0631\u0633\u06cc\u062f<\/span><\/div>\n
<\/div>\n
\u0647\u0645\u0686\u0646\u06cc\u0646 \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u06cc\u062f \u067e\u06cc\u0627\u0645\u200c\u0647\u0627\u06cc \u0645\u0635\u0631\u0641 \u0634\u062f\u0647 \u0631\u0627 \u0628\u0647\u200c\u0635\u0648\u0631\u062a JSON \u062e\u0631\u0648\u062c\u06cc \u06a9\u0646\u06cc\u062f \u0628\u0627 \u0648\u0627\u0631\u062f \u06a9\u0631\u062f\u0646<\/span> -J:<\/span><\/div>\n
kcat<\/span> -b<\/span> kafka1.your_domain:9092<\/span> -t<\/span> java_demo<\/span> -J<\/span><\/div>\n
<\/div>\n
\u062e\u0631\u0648\u062c\u06cc \u0634\u0628\u06cc\u0647 \u0628\u0647 \u0627\u06cc\u0646 \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f:<\/span><\/div>\n
\u062e\u0631\u0648\u062c\u06cc<\/span><\/div>\n
% \u0627\u0646\u062a\u062e\u0627\u0628 \u062e\u0648\u062f\u06a9\u0627\u0631 \u062d\u0627\u0644\u062a \u0645\u0635\u0631\u0641\u200c\u06a9\u0646\u0646\u062f\u0647<\/span> (\u0628\u0631\u0627\u06cc<\/span> \u0644\u063a\u0648 \u0627\u0632<\/span> -P<\/span> \u06cc\u0627<\/span> -C<\/span> \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u06a9\u0646\u06cc\u062f)<\/span><\/div>\n
% \u0628\u0647 \u0627\u0646\u062a\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639 java_demo<\/span> [2]<\/span> \u062f\u0631 \u0627\u0641\u0633\u062a 0 \u0631\u0633\u06cc\u062f<\/span><\/div>\n
% \u0628\u0647 \u0627\u0646\u062a\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639 java_demo<\/span> [0]<\/span> \u062f\u0631 \u0627\u0641\u0633\u062a 0 \u0631\u0633\u06cc\u062f<\/span><\/div>\n
% \u0628\u0647 \u0627\u0646\u062a\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639 java_demo<\/span> [1]<\/span> \u062f\u0631 \u0627\u0641\u0633\u062a 0 \u0631\u0633\u06cc\u062f<\/span><\/div>\n
{\u201ctopic\u201d:\u201cjava_demo\u201d,\u201cpartition\u201d:4,\u201coffset\u201d:0,\u201ctstype\u201d:\u201ccreate\u201d,\u201cts\u201d:1714922509999,\u201cbroker\u201d:1,\u201ckey\u201d:null,\u201cpayload\u201d:\u201cHello World!\u201d}<\/span><\/div>\n
% \u0628\u0647 \u0627\u0646\u062a\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639 java_demo<\/span> [3]<\/span> \u062f\u0631 \u0627\u0641\u0633\u062a 0 \u0631\u0633\u06cc\u062f<\/span><\/div>\n
% \u0628\u0647 \u0627\u0646\u062a\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639 java_demo<\/span> [5]<\/span> \u062f\u0631 \u0627\u0641\u0633\u062a 0 \u0631\u0633\u06cc\u062f<\/span><\/div>\n
% \u0628\u0647 \u0627\u0646\u062a\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639 java_demo<\/span> [4]<\/span> \u062f\u0631 \u0627\u0641\u0633\u062a 1 \u0631\u0633\u06cc\u062f<\/span><\/div>\n
<\/div>\n
\u0628\u0631\u0627\u06cc \u062a\u0648\u0644\u06cc\u062f \u067e\u06cc\u0627\u0645\u200c\u0647\u0627 \u0628\u0647 \u06cc\u06a9 \u0645\u0648\u0636\u0648\u0639\u060c \u0628\u0627\u06cc\u062f<\/span> -P<\/span> \u0631\u0627 \u0648\u0627\u0631\u062f \u06a9\u0646\u06cc\u062f \u062a\u0627 \u0628\u0647 \u062d\u0627\u0644\u062a \u062a\u0648\u0644\u06cc\u062f\u06a9\u0646\u0646\u062f\u0647 \u062a\u063a\u06cc\u06cc\u0631 \u0648\u0636\u0639\u06cc\u062a \u062f\u0647\u06cc\u062f:<\/span><\/div>\n
kcat<\/span> -b<\/span> kafka1.your_domain:9092<\/span> -t<\/span> java_demo<\/span> -P<\/span><\/div>\n
<\/div>\n
\u0645\u0627\u0646\u0646\u062f kafka-console-producer.sh\u060c kcat \u067e\u06cc\u0627\u0645\u200c\u0647\u0627 \u0631\u0627 \u06a9\u0647 \u0628\u0627 ENTER \u062c\u062f\u0627 \u0634\u062f\u0647\u200c\u0627\u0646\u062f\u060c \u0645\u06cc\u200c\u067e\u0630\u06cc\u0631\u062f. \u0628\u0631\u0627\u06cc \u062e\u0631\u0648\u062c \u0627\u0632 \u067e\u0631\u0627\u0645\u067e\u062a\u060c \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u06cc\u062f CTRL + C \u0631\u0627 \u0641\u0634\u0627\u0631 \u062f\u0647\u06cc\u062f \u0648 \u0633\u067e\u0633 ENTER \u0631\u0627 \u0628\u0632\u0646\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
\u0634\u0645\u0627 \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u06cc\u062f \u0627\u0632 \u0642\u0627\u0628\u0644\u06cc\u062a \u0627\u0644\u06af\u0648\u0647\u0627\u06cc kcat \u0628\u0631\u0627\u06cc \u062e\u0631\u0648\u062c\u06cc \u06af\u0631\u0641\u062a\u0646 \u0627\u0637\u0644\u0627\u0639\u0627\u062a \u0628\u06cc\u0634\u062a\u0631 \u062f\u0631 \u0645\u0648\u0631\u062f \u06cc\u06a9 \u067e\u06cc\u0627\u0645 \u0647\u0645\u0631\u0627\u0647 \u0628\u0627 \u0622\u0646 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u06a9\u0646\u06cc\u062f. \u0628\u0631\u0627\u06cc \u0648\u0627\u0631\u062f \u06a9\u0631\u062f\u0646 \u0642\u0627\u0644\u0628 \u062f\u0644\u062e\u0648\u0627\u0647 \u062e\u0648\u062f\u060c \u0627\u0632<\/span> -f<\/span> \u0645\u0627\u0646\u0646\u062f \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
kcat<\/span> -b<\/span> kafka1.your_domain:9092<\/span> -t<\/span> java_demo<\/span> -f<\/span> \u2018Topic<\/span> %t[%p], offset: %o, key: %k, payload: %S bytes: %s\\n\u2019<\/span><\/div>\n
<\/div>\n
\u062f\u0631 \u0627\u06cc\u0646\u062c\u0627\u060c \u0634\u0645\u0627 \u0628\u0647 \u0622\u0646 \u062f\u0633\u062a\u0648\u0631 \u0645\u06cc\u200c\u062f\u0647\u06cc\u062f \u06a9\u0647 \u062a\u0645\u0627\u0645 \u067e\u06cc\u0627\u0645\u200c\u0647\u0627 \u0631\u0627 \u0627\u0632 \u0627\u0628\u062a\u062f\u0627 \u0627\u0632 java_demotopic \u0628\u062e\u0648\u0627\u0646\u062f \u0648 \u0646\u0627\u0645 \u0645\u0648\u0636\u0648\u0639<\/span> (%t)\u060c<\/span> \u0634\u0645\u0627\u0631\u0647 \u067e\u0627\u0631\u062a\u06cc\u0634\u0646<\/span> (%p)\u060c<\/span> \u0627\u0641\u0633\u062a<\/span> (%o)\u060c<\/span> \u06a9\u0644\u06cc\u062f \u067e\u06cc\u0627\u0645<\/span> (%k)\u060c<\/span> \u0637\u0648\u0644 \u0645\u0642\u062f\u0627\u0631<\/span> (%S)<\/span> \u0648 \u062e\u0648\u062f \u067e\u06cc\u0627\u0645<\/span> (%s)<\/span> \u0631\u0627 \u062e\u0631\u0648\u062c\u06cc \u06a9\u0646\u062f.<\/span><\/div>\n
\u062e\u0631\u0648\u062c\u06cc \u0634\u0628\u06cc\u0647 \u0628\u0647 \u0627\u06cc\u0646 \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f:<\/span><\/div>\n
% \u0627\u0646\u062a\u062e\u0627\u0628 \u062e\u0648\u062f\u06a9\u0627\u0631 \u062d\u0627\u0644\u062a \u0645\u0635\u0631\u0641\u200c\u06a9\u0646\u0646\u062f\u0647<\/span> (\u0628\u0631\u0627\u06cc<\/span> \u0644\u063a\u0648 \u0627\u0632<\/span> -P<\/span> \u06cc\u0627<\/span> -C<\/span> \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u06a9\u0646\u06cc\u062f)<\/span><\/div>\n
% \u0628\u0647 \u0627\u0646\u062a\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639 java_demo<\/span> [2]<\/span> \u062f\u0631 \u0627\u0641\u0633\u062a 0 \u0631\u0633\u06cc\u062f<\/span><\/div>\n
% \u0628\u0647 \u0627\u0646\u062a\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639 java_demo<\/span> [1]<\/span> \u062f\u0631 \u0627\u0641\u0633\u062a 0 \u0631\u0633\u06cc\u062f<\/span><\/div>\n
Topic java_demo[4], offset: 0, key: , payload: 12 bytes: Hello World!<\/span><\/div>\n
% \u0628\u0647 \u0627\u0646\u062a\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639 java_demo<\/span> [0]<\/span> \u062f\u0631 \u0627\u0641\u0633\u062a 0 \u0631\u0633\u06cc\u062f<\/span><\/div>\n
% \u0628\u0647 \u0627\u0646\u062a\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639 java_demo<\/span> [3]<\/span> \u062f\u0631 \u0627\u0641\u0633\u062a 0 \u0631\u0633\u06cc\u062f<\/span><\/div>\n
% \u0628\u0647 \u0627\u0646\u062a\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639 java_demo<\/span> [4]<\/span> \u062f\u0631 \u0627\u0641\u0633\u062a 1 \u0631\u0633\u06cc\u062f<\/span><\/div>\n
% \u0628\u0647 \u0627\u0646\u062a\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639 java_demo<\/span> [5]<\/span> \u062f\u0631 \u0627\u0641\u0633\u062a 0 \u0631\u0633\u06cc\u062f<\/span><\/div>\n
<\/div>\n
kcat \u0627\u0632 \u0642\u0627\u0644\u0628 \u0631\u0634\u062a\u0647\u200c\u0627\u06cc \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u06a9\u0631\u062f \u0648 \u0627\u0637\u0644\u0627\u0639\u0627\u062a \u0627\u0636\u0627\u0641\u06cc \u062f\u0631 \u0645\u0648\u0631\u062f \u0631\u06a9\u0648\u0631\u062f \u067e\u06cc\u0627\u0645 \u0631\u0627 \u062e\u0631\u0648\u062c\u06cc \u06a9\u0631\u062f.<\/span><\/div>\n
<\/div>\n
\u0641\u0647\u0631\u0633\u062a\u200c\u06a9\u0631\u062f\u0646 \u0645\u062a\u0627\u062f\u0627\u062f\u0647 \u06a9\u0644\u0627\u0633\u062a\u0631<\/span><\/div>\n
\u0634\u0645\u0627 \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u06cc\u062f \u0645\u062a\u0627\u062f\u0627\u062f\u0647 \u06a9\u0644\u0627\u0633\u062a\u0631 \u0631\u0627 \u0628\u0647\u200c\u0637\u0648\u0631 \u0645\u0646\u0638\u0645 \u0628\u0627 \u0648\u0627\u0631\u062f \u06a9\u0631\u062f\u0646<\/span> -L<\/span> \u0641\u0647\u0631\u0633\u062a \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
kcat<\/span> -b<\/span> kafka1.your_domain:9092<\/span> -L<\/span><\/div>\n
<\/div>\n
\u062e\u0631\u0648\u062c\u06cc \u062a\u0645\u0627\u0645 \u0628\u0631\u0648\u06a9\u0631\u0647\u0627\u06cc \u06a9\u0644\u0627\u0633\u062a\u0631 \u0631\u0627 \u0628\u0647\u200c\u0647\u0645\u0631\u0627\u0647 \u062a\u0645\u0627\u0645 \u0645\u0648\u0636\u0648\u0639\u200c\u0647\u0627 \u0648 \u067e\u0627\u0631\u062a\u06cc\u0634\u0646\u200c\u0647\u0627\u06cc\u0634\u0627\u0646 \u0641\u0647\u0631\u0633\u062a \u0645\u06cc\u200c\u06a9\u0646\u062f:<\/span><\/div>\n
\u062e\u0631\u0648\u062c\u06cc<\/span><\/div>\n
3 \u0628\u0631\u0648\u06a9\u0631:<\/span><\/div>\n
\u0628\u0631\u0648\u06a9\u0631 1 \u062f\u0631 kafka1.your_domain:9092<\/span><\/div>\n
\u0628\u0631\u0648\u06a9\u0631 2 \u062f\u0631 kafka2.your_domain:9092<\/span> (\u06a9\u0646\u062a\u0631\u0644\u200c\u06a9\u0646\u0646\u062f\u0647)<\/span><\/div>\n
\u0628\u0631\u0648\u06a9\u0631 3 \u062f\u0631 kafka3.your_domain:9092<\/span><\/div>\n
1 \u0645\u0648\u0636\u0648\u0639:<\/span><\/div>\n
\u0645\u0648\u0636\u0648\u0639<\/span> \u201cjava_demo\u201d<\/span> \u0628\u0627 6 \u067e\u0627\u0631\u062a\u06cc\u0634\u0646:<\/span><\/div>\n
\u067e\u0627\u0631\u062a\u06cc\u0634\u0646 0\u060c \u0631\u0647\u0628\u0631 3\u060c \u0646\u0633\u062e\u0647\u200c\u0647\u0627: 3,1\u060c \u0646\u0645\u0627\u06cc\u0646\u062f\u06af\u0627\u0646 \u0647\u0645\u200c\u0632\u0645\u0627\u0646: 3,1<\/span><\/div>\n
\u067e\u0627\u0631\u062a\u06cc\u0634\u0646 1\u060c \u0631\u0647\u0628\u0631 1\u060c \u0646\u0633\u062e\u0647\u200c\u0647\u0627: 1,2\u060c \u0646\u0645\u0627\u06cc\u0646\u062f\u06af\u0627\u0646 \u0647\u0645\u200c\u0632\u0645\u0627\u0646: 1,2<\/span><\/div>\n
\u067e\u0627\u0631\u062a\u06cc\u0634\u0646 2\u060c \u0631\u0647\u0628\u0631 2\u060c \u0646\u0633\u062e\u0647\u200c\u0647\u0627: 2,3\u060c \u0646\u0645\u0627\u06cc\u0646\u062f\u06af\u0627\u0646 \u0647\u0645\u200c\u0632\u0645\u0627\u0646: 2,3<\/span><\/div>\n
\u067e\u0627\u0631\u062a\u06cc\u0634\u0646 3\u060c \u0631\u0647\u0628\u0631 2\u060c \u0646\u0633\u062e\u0647\u200c\u0647\u0627: 2,1\u060c \u0646\u0645\u0627\u06cc\u0646\u062f\u06af\u0627\u0646 \u0647\u0645\u200c\u0632\u0645\u0627\u0646: 2,1<\/span><\/div>\n
\u067e\u0627\u0631\u062a\u06cc\u0634\u0646 4\u060c \u0631\u0647\u0628\u0631 1\u060c \u0646\u0633\u062e\u0647\u200c\u0647\u0627: 1,3\u060c \u0646\u0645\u0627\u06cc\u0646\u062f\u06af\u0627\u0646 \u0647\u0645\u200c\u0632\u0645\u0627\u0646: 1,3<\/span><\/div>\n
\u067e\u0627\u0631\u062a\u06cc\u0634\u0646 5\u060c \u0631\u0647\u0628\u0631 3\u060c \u0646\u0633\u062e\u0647\u200c\u0647\u0627: 3,2\u060c \u0646\u0645\u0627\u06cc\u0646\u062f\u06af\u0627\u0646 \u0647\u0645\u200c\u0632\u0645\u0627\u0646: 3,2<\/span><\/div>\n
<\/div>\n
\u0628\u0647\u200c\u0637\u0648\u0631 \u0645\u0634\u0627\u0628\u0647 \u0628\u0627 \u0627\u0633\u06a9\u0631\u06cc\u067e\u062a Kafka-topics.sh\u060c kcat \u0631\u0647\u0628\u0631\u0627\u0646 \u067e\u0627\u0631\u062a\u06cc\u0634\u0646\u200c\u0647\u0627\u060c \u0646\u0633\u062e\u0647\u200c\u0647\u0627 \u0648 \u0645\u062c\u0645\u0648\u0639\u0647\u200c\u0647\u0627\u06cc \u0646\u0633\u062e\u0647\u200c\u0647\u0627\u06cc \u0647\u0645\u200c\u0632\u0645\u0627\u0646 \u0631\u0627 \u0641\u0647\u0631\u0633\u062a \u0645\u06cc\u200c\u06a9\u0646\u062f.<\/span><\/div>\n
<\/div>\n
\u0647\u0645\u0686\u0646\u06cc\u0646 \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u06cc\u062f \u0628\u0627 \u0648\u0627\u0631\u062f \u06a9\u0631\u062f\u0646<\/span> -J<\/span> \u062e\u0631\u0648\u062c\u06cc \u0631\u0627 \u0628\u0647\u200c\u0635\u0648\u0631\u062a JSON \u062f\u0631\u06cc\u0627\u0641\u062a \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
kcat<\/span> -b<\/span> kafka1.your_domain:9092<\/span> -L<\/span> -J<\/span><\/div>\n
<\/div>\n
\u062e\u0631\u0648\u062c\u06cc \u0634\u0628\u06cc\u0647 \u0628\u0647 \u0627\u06cc\u0646 \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f:<\/span><\/div>\n
\u062e\u0631\u0648\u062c\u06cc<\/span><\/div>\n
{<\/span><\/div>\n
\u201coriginating_broker\u201d: {<\/span><\/div>\n
\u201cid\u201d: 2,<\/span><\/div>\n
\u201cname\u201d:<\/span> \u201ckafka2.your_domain:9092\/2\u201d<\/span><\/div>\n
},<\/span><\/div>\n
\u201cquery\u201d: {<\/span><\/div>\n
\u201ctopic\u201d:<\/span> \u201c*\u201d<\/span><\/div>\n
},<\/span><\/div>\n
\u201ccontrollerid\u201d: 3,<\/span><\/div>\n
\u201cbrokers\u201d: [<\/span><\/div>\n
{<\/span><\/div>\n
\u201cid\u201d: 1,<\/span><\/div>\n
\u201cname\u201d:<\/span> \u201ckafka1.your_domain:9092\u201d<\/span><\/div>\n
},<\/span><\/div>\n
{<\/span><\/div>\n
\u201cid\u201d: 2,<\/span><\/div>\n
\u201cname\u201d:<\/span> \u201ckafka2.your_domain:9092\u201d<\/span><\/div>\n
},<\/span><\/div>\n
{<\/span><\/div>\n
\u201cid\u201d: 3,<\/span><\/div>\n
\u201cname\u201d:<\/span> \u201ckafka3.your_domain:9092\u201d<\/span><\/div>\n
}<\/span><\/div>\n
],<\/span><\/div>\n
\u201ctopics\u201d: [<\/span><\/div>\n
{<\/span><\/div>\n
\u201ctopic\u201d:<\/span> \u201cjava_demo\u201d,<\/span><\/div>\n
\u201cpartitions\u201d: [<\/span><\/div>\n
{<\/span><\/div>\n
\u201cpartition\u201d: 0,<\/span><\/div>\n
\u201cleader\u201d: 3,<\/span><\/div>\n
\u201creplicas\u201d: [<\/span><\/div>\n
{<\/span><\/div>\n
\u201cid\u201d: 3<\/span><\/div>\n
}<\/span><\/div>\n
],<\/span><\/div>\n
\u201cisrs\u201d: [<\/span><\/div>\n
{<\/span><\/div>\n
\u201cid\u201d: 3<\/span><\/div>\n
}<\/span><\/div>\n
]<\/span><\/div>\n
},<\/span><\/div>\n
\u2026<\/span><\/div>\n
]<\/span><\/div>\n
}<\/span><\/div>\n
]<\/span><\/div>\n
}<\/span><\/div>\n
<\/div>\n
\u062f\u0631 \u0627\u06cc\u0646 \u0645\u0631\u062d\u0644\u0647\u060c \u0634\u0645\u0627 kcat \u0631\u0627 \u0646\u0635\u0628 \u06a9\u0631\u062f\u0647\u200c\u0627\u06cc\u062f\u060c \u0627\u0628\u0632\u0627\u0631\u06cc \u0628\u0631\u0627\u06cc \u062f\u0633\u062a\u0631\u0633\u06cc \u0648 \u0645\u062f\u06cc\u0631\u06cc\u062a \u0622\u0633\u0627\u0646 \u06a9\u0644\u0627\u0633\u062a\u0631\u0647\u0627\u06cc Kafka \u0628\u062f\u0648\u0646 \u0646\u06cc\u0627\u0632 \u0628\u0647 Java. \u0634\u0645\u0627 \u06cc\u0627\u062f \u06af\u0631\u0641\u062a\u06cc\u062f \u06a9\u0647 \u0686\u06af\u0648\u0646\u0647 \u0627\u0637\u0644\u0627\u0639\u0627\u062a\u06cc \u062f\u0631 \u0645\u0648\u0631\u062f \u06a9\u0644\u0627\u0633\u062a\u0631 \u0648 \u0645\u0648\u0636\u0648\u0639\u200c\u0647\u0627\u06cc \u0622\u0646 \u0628\u0647\u200c\u062f\u0633\u062a \u0622\u0648\u0631\u06cc\u062f\u060c \u0647\u0645\u0686\u0646\u06cc\u0646 \u0686\u06af\u0648\u0646\u06af\u06cc \u062a\u0648\u0644\u06cc\u062f \u0648 \u0645\u0635\u0631\u0641 \u067e\u06cc\u0627\u0645\u200c\u0647\u0627 \u0631\u0627 \u0622\u0645\u0648\u062e\u062a\u06cc\u062f. \u0627\u06a9\u0646\u0648\u0646 \u062e\u0648\u0627\u0647\u06cc\u062f \u0622\u0645\u0648\u062e\u062a \u06a9\u0647 \u0686\u06af\u0648\u0646\u0647 \u0628\u0627 Cruise Control\u060c \u062a\u0639\u0627\u062f\u0644 \u0645\u062c\u062f\u062f \u0645\u0646\u0627\u0633\u0628 \u062f\u0631\u0648\u0646 \u06a9\u0644\u0627\u0633\u062a\u0631 \u0631\u0627 \u062e\u0648\u062f\u06a9\u0627\u0631 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
\u06af\u0627\u0645 3 – \u062e\u0648\u062f\u06a9\u0627\u0631\u0633\u0627\u0632\u06cc \u062a\u063a\u06cc\u06cc\u0631\u0627\u062a \u062a\u0639\u0627\u062f\u0644 \u0628\u0627 Kafka Cruise Control<\/span><\/div>\n
Cruise Control \u06cc\u06a9 \u067e\u0631\u0648\u0698\u0647 \u0645\u062a\u0646\u200c\u0628\u0627\u0632 \u0627\u0633\u062a \u06a9\u0647 \u062a\u0648\u0633\u0637 LinkedIn \u062a\u0648\u0633\u0639\u0647 \u062f\u0627\u062f\u0647 \u0634\u062f\u0647 \u0648 \u0628\u0647\u200c\u0637\u0648\u0631 \u0645\u062f\u0627\u0648\u0645 \u0641\u0639\u0627\u0644\u06cc\u062a\u200c\u0647\u0627\u06cc \u0628\u0631\u0648\u06a9\u0631\u0647\u0627\u06cc Kafka \u062f\u0631 \u06cc\u06a9 \u06a9\u0644\u0627\u0633\u062a\u0631 \u0631\u0627 \u0646\u0638\u0627\u0631\u062a \u0645\u06cc\u200c\u06a9\u0646\u062f \u0648 \u0628\u0627\u0631 \u06a9\u0627\u0631\u06cc \u0631\u0627 \u062f\u0648\u0628\u0627\u0631\u0647 \u062a\u0639\u0627\u062f\u0644 \u0645\u06cc\u200c\u06a9\u0646\u062f \u062a\u0627 \u0645\u0635\u0631\u0641 \u0645\u0646\u0627\u0628\u0639 \u0648 \u06a9\u0627\u0631\u0627\u06cc\u06cc \u0631\u0627 \u0628\u0647\u06cc\u0646\u0647\u200c\u0633\u0627\u0632\u06cc \u06a9\u0646\u062f. \u062f\u0631 \u0627\u06cc\u0646 \u06af\u0627\u0645\u060c \u0634\u0645\u0627 \u06cc\u0627\u062f \u062e\u0648\u0627\u0647\u06cc\u062f \u06af\u0631\u0641\u062a \u06a9\u0647 \u0686\u06af\u0648\u0646\u0647 \u0622\u0646 \u0631\u0627 \u0628\u0631\u0627\u06cc \u06a9\u0644\u0627\u0633\u062a\u0631 \u062e\u0648\u062f \u0641\u0639\u0627\u0644 \u06a9\u0646\u06cc\u062f \u0648 \u0639\u0645\u0644\u06cc\u0627\u062a\u200c\u0647\u0627\u06cc \u0622\u0646 \u0631\u0627 \u0646\u0638\u0627\u0631\u062a \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
\u0628\u0647\u200c\u0637\u0648\u0631 \u067e\u06cc\u0634\u200c\u0641\u0631\u0636\u060c Cruise Control \u0627\u0647\u062f\u0627\u0641 \u0645\u0639\u0642\u0648\u0644\u06cc \u0628\u0631\u0627\u06cc \u0627\u0637\u0645\u06cc\u0646\u0627\u0646 \u0627\u0632 \u0639\u0645\u0644\u06a9\u0631\u062f \u0628\u0647\u06cc\u0646\u0647 \u06a9\u0644\u0627\u0633\u062a\u0631 \u062f\u0627\u0631\u062f \u06a9\u0647 \u0628\u0647 \u0622\u0646\u200c\u0647\u0627<\/span> \u201cgoal\u201d<\/span> \u06af\u0641\u062a\u0647 \u0645\u06cc\u200c\u0634\u0648\u062f. \u0628\u0631\u062e\u06cc \u0627\u0632 \u0627\u0647\u062f\u0627\u0641 \u0627\u0635\u0644\u06cc \u0634\u0627\u0645\u0644 \u0627\u0637\u0645\u06cc\u0646\u0627\u0646 \u0627\u0632 \u062f\u0627\u0634\u062a\u0646 \u062a\u0639\u062f\u0627\u062f \u0645\u0646\u0627\u0633\u0628 \u0631\u067e\u0644\u06cc\u06a9\u0627\u06cc \u0647\u0631 \u0645\u0648\u0636\u0648\u0639\u060c \u062d\u0641\u0638 \u062a\u0639\u0627\u062f\u0644 \u0645\u0635\u0631\u0641 CPU\u060c \u0634\u0628\u06a9\u0647 \u0648 \u062f\u06cc\u0633\u06a9 \u0648 \u0645\u062d\u062f\u0648\u062f \u06a9\u0631\u062f\u0646 \u0622\u0646\u200c\u0647\u0627 \u062a\u062d\u062a \u0645\u0642\u0627\u062f\u06cc\u0631 \u0645\u0634\u062e\u0635\u060c \u0648 \u062f\u0627\u0634\u062a\u0646 \u0631\u067e\u0644\u06cc\u06a9\u0627\u06cc \u06a9\u0627\u0641\u06cc \u0628\u0631\u0627\u06cc \u067e\u0627\u0631\u062a\u06cc\u0634\u0646\u200c\u0647\u0627\u06cc \u0645\u0648\u0636\u0648\u0639 \u0627\u0633\u062a. \u067e\u06cc\u0627\u062f\u0647\u200c\u0633\u0627\u0632\u06cc \u0627\u0647\u062f\u0627\u0641 \u0633\u0641\u0627\u0631\u0634\u06cc \u0646\u06cc\u0632 \u067e\u0634\u062a\u06cc\u0628\u0627\u0646\u06cc \u0645\u06cc\u200c\u0634\u0648\u062f.<\/span><\/div>\n
\u0634\u0645\u0627 \u0628\u0627\u06cc\u062f Cruise Control \u0631\u0627 \u0627\u0632 \u0645\u0646\u0628\u0639 \u06a9\u0627\u0645\u067e\u0627\u06cc\u0644 \u06a9\u0646\u06cc\u062f. \u0627\u0628\u062a\u062f\u0627\u060c \u0645\u062e\u0632\u0646 \u0631\u0633\u0645\u06cc Git \u0631\u0627 \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u06a9\u0644\u0648\u0646 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
git clone <\/span>https:\/\/github.com\/linkedin\/cruise-control.git<\/a><\/span><\/div>\n
\u0628\u0647 \u0622\u0646 \u0628\u0631\u0648\u06cc\u062f:<\/span><\/div>\n
cd cruise-control<\/span><\/div>\n
\u0633\u067e\u0633 \u0627\u0632 Gradle \u0628\u0631\u0627\u06cc \u06a9\u0627\u0645\u067e\u0627\u06cc\u0644 \u067e\u0631\u0648\u0698\u0647 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
.\/gradlew jar<\/span><\/div>\n
\u0641\u0631\u0622\u06cc\u0646\u062f \u0633\u0627\u062e\u062a \u0632\u0645\u0627\u0646\u200c\u0628\u0631 \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f. \u0627\u0646\u062a\u0647\u0627\u06cc \u062e\u0631\u0648\u062c\u06cc \u0645\u0634\u0627\u0628\u0647 \u0627\u06cc\u0646 \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f:<\/span><\/div>\n
BUILD SUCCESSFUL in 2m 41s<\/span><\/div>\n
17 actionable tasks: 17 executed<\/span><\/div>\n
\u0627\u06a9\u0646\u0648\u0646 Cruise Control \u0628\u0647 \u0647\u0645\u0631\u0627\u0647 \u06af\u0632\u0627\u0631\u0634\u200c\u062f\u0647\u0646\u062f\u0647 \u0645\u062a\u0631\u06cc\u06a9\u200c\u0647\u0627\u06cc \u0622\u0646 \u06a9\u0627\u0645\u067e\u0627\u06cc\u0644 \u0634\u062f\u0647 \u0627\u0633\u062a \u06a9\u0647 \u062f\u0631 \u0645\u0633\u06cc\u0631 cruise-control-metrics-reporter\/build\/libs\/ \u062f\u0631 \u06cc\u06a9 \u0641\u0627\u06cc\u0644 JAR \u0642\u0631\u0627\u0631 \u062f\u0627\u0631\u062f. \u0627\u06cc\u0646 \u06af\u0632\u0627\u0631\u0634\u200c\u062f\u0647\u0646\u062f\u0647 \u0645\u062a\u0631\u06cc\u06a9\u200c\u0647\u0627\u06cc\u06cc \u062f\u0631 \u0645\u0648\u0631\u062f \u06cc\u06a9 \u0628\u0631\u0648\u06a9\u0631 \u0628\u0647 \u06cc\u06a9 \u0645\u0648\u0636\u0648\u0639 \u062f\u0631 \u06a9\u0644\u0627\u0633\u062a\u0631 \u0627\u0631\u0633\u0627\u0644 \u0645\u06cc\u200c\u06a9\u0646\u062f \u06a9\u0647 Cruise Control \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u062f \u0622\u0646\u200c\u0647\u0627 \u0631\u0627 \u0646\u0638\u0627\u0631\u062a \u06a9\u0646\u062f.<\/span><\/div>\n
\u0633\u067e\u0633\u060c \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u0631\u0627 \u0628\u0631\u0627\u06cc \u06a9\u067e\u06cc \u06a9\u0631\u062f\u0646 \u062a\u0645\u0627\u0645 \u0648\u0627\u0628\u0633\u062a\u06af\u06cc\u200c\u0647\u0627 \u0628\u0647 \u062f\u0627\u06cc\u0631\u06a9\u062a\u0648\u0631\u06cc \u0647\u062f\u0641 \u0627\u062c\u0631\u0627 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
.\/gradlew jar copyDependantLibs<\/span><\/div>\n
\u062e\u0631\u0648\u062c\u06cc \u0628\u0647 \u0634\u06a9\u0644 \u0632\u06cc\u0631 \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f:<\/span><\/div>\n
BUILD SUCCESSFUL in 15s<\/span><\/div>\n
17 actionable tasks: 1 executed, 16 up-to-date<\/span><\/div>\n
\u062f\u0631 \u0645\u0631\u062d\u0644\u0647 \u0628\u0639\u062f\u060c \u0634\u0645\u0627 \u0628\u0627\u06cc\u062f \u0647\u0631 \u0628\u0631\u0648\u06a9\u0631 Kafka \u062f\u0631 \u06a9\u0644\u0627\u0633\u062a\u0631 \u0631\u0627 \u0628\u0631\u0627\u06cc \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 \u06af\u0632\u0627\u0631\u0634\u200c\u062f\u0647\u0646\u062f\u0647 \u0645\u062a\u0631\u06cc\u06a9 \u062c\u062f\u06cc\u062f \u067e\u06cc\u06a9\u0631\u0628\u0646\u062f\u06cc \u06a9\u0646\u06cc\u062f. \u0622\u0646 \u0631\u0627 \u0628\u0647 \u062f\u0627\u06cc\u0631\u06a9\u062a\u0648\u0631\u06cc libs\/ \u06a9\u0647 \u062f\u0631 \u0622\u0646 Kafka \u0646\u0635\u0628 \u0634\u062f\u0647 \u0627\u0633\u062a \u06a9\u067e\u06cc \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
cp cruise-control-metrics-reporter\/build\/libs\/* \/home\/kafka\/kafka\/libs\/<\/span><\/div>\n
\u0633\u067e\u0633\u060c \u0634\u0645\u0627 \u0628\u0627\u06cc\u062f \u067e\u06cc\u06a9\u0631\u0628\u0646\u062f\u06cc \u0628\u0631\u0648\u06a9\u0631 Kafka \u0631\u0627 \u0628\u0631\u0627\u06cc \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 \u06af\u0632\u0627\u0631\u0634\u200c\u062f\u0647\u0646\u062f\u0647 \u062c\u062f\u06cc\u062f \u062a\u063a\u06cc\u06cc\u0631 \u062f\u0647\u06cc\u062f. \u0641\u0627\u06cc\u0644 server.properties \u0645\u0631\u0628\u0648\u0637 \u0628\u0647 \u0628\u0631\u0648\u06a9\u0631 \u0631\u0627 \u0628\u0631\u0627\u06cc \u0648\u06cc\u0631\u0627\u06cc\u0634 \u0628\u0627\u0632 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
nano \/home\/kafka\/kafka\/config\/kraft\/server.properties<\/span><\/div>\n
\u0627\u06cc\u0646 \u062e\u0637 \u0631\u0627 \u062f\u0631 \u0627\u0646\u062a\u0647\u0627\u06cc \u0641\u0627\u06cc\u0644 \u0627\u0636\u0627\u0641\u0647 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
metric.reporters=com.linkedin.kafka.cruisecontrol.metricsreporter.CruiseControlMetricsReporter<\/span><\/div>\n
\u067e\u0633 \u0627\u0632 \u0627\u062a\u0645\u0627\u0645\u060c \u0641\u0627\u06cc\u0644 \u0631\u0627 \u0630\u062e\u06cc\u0631\u0647 \u0648 \u0628\u0633\u062a\u0647 \u06a9\u0646\u06cc\u062f. \u0628\u0631\u0648\u06a9\u0631 \u0631\u0627 \u0628\u0627 \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u0645\u062c\u062f\u062f\u0627\u064b \u0631\u0627\u0647\u200c\u0627\u0646\u062f\u0627\u0632\u06cc \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
sudo systemctl restart kafka<\/span><\/div>\n
\u062a\u0645\u0627\u0645 \u0628\u0631\u0648\u06a9\u0631\u0647\u0627\u06cc \u06a9\u0644\u0627\u0633\u062a\u0631 \u0628\u0627\u06cc\u062f \u06af\u0632\u0627\u0631\u0634\u200c\u062f\u0647\u0646\u062f\u0647 \u0645\u062a\u0631\u06cc\u06a9 Cruise Control \u0631\u0627 \u0641\u0639\u0627\u0644 \u06a9\u0631\u062f\u0647 \u0628\u0627\u0634\u0646\u062f\u060c \u0628\u0646\u0627\u0628\u0631\u0627\u06cc\u0646 \u0645\u0631\u0627\u062d\u0644 \u0628\u0627\u0644\u0627 \u0631\u0627 \u062f\u0631 \u0633\u0627\u06cc\u0631 \u06af\u0631\u0647\u200c\u0647\u0627 \u0646\u06cc\u0632 \u062a\u06a9\u0631\u0627\u0631 \u06a9\u0646\u06cc\u062f \u062a\u0627 \u06af\u0632\u0627\u0631\u0634\u200c\u062f\u0647\u0646\u062f\u0647 \u0645\u062a\u0631\u06cc\u06a9 JAR \u0631\u0627 \u062f\u0631\u06cc\u0627\u0641\u062a \u06a9\u0646\u06cc\u062f. \u067e\u0633 \u0627\u0632 \u0686\u0646\u062f \u062f\u0642\u06cc\u0642\u0647\u060c \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u06cc\u062f \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 \u062f\u0633\u062a\u0648\u0631 kcat \u0645\u0648\u0636\u0648\u0639\u0627\u062a \u0645\u0648\u062c\u0648\u062f \u062f\u0631 \u06a9\u0644\u0627\u0633\u062a\u0631 \u0631\u0627 \u0641\u0647\u0631\u0633\u062a \u06a9\u0646\u06cc\u062f \u062a\u0627 \u062a\u0623\u06cc\u06cc\u062f \u06a9\u0646\u06cc\u062f \u06a9\u0647 \u06af\u0632\u0627\u0631\u0634\u200c\u062f\u0647\u0646\u062f\u0647 \u0645\u062a\u0631\u06cc\u06a9 \u0634\u0631\u0648\u0639 \u0628\u0647 \u06a9\u0627\u0631 \u06a9\u0631\u062f\u0647 \u0627\u0633\u062a:<\/span><\/div>\n
Output<\/span><\/div>\n
…<\/span><\/div>\n
\u00a0 topic<\/span> “__CruiseControlMetrics”<\/span> with 6 partitions:<\/span><\/div>\n
\u00a0 \u00a0 partition 0, leader 3, replicas: 3,2 isrs: 3,2<\/span><\/div>\n
\u00a0 \u00a0 partition 1, leader 2, replicas: 2,3 isrs: 2,3<\/span><\/div>\n
\u00a0 \u00a0 partition 2, leader 3, replicas: 3,2 isrs: 3,2<\/span><\/div>\n
\u00a0 \u00a0 partition 3, leader 2, replicas: 2,3 isrs: 2,3<\/span><\/div>\n
\u00a0 \u00a0 partition 4, leader 2, replicas: 2,3 isrs: 2,3<\/span><\/div>\n
\u00a0 \u00a0 partition 5, leader 3, replicas: 3,2 isrs: 3,2<\/span><\/div>\n
\u0628\u0631\u0627\u06cc \u0628\u0647\u06cc\u0646\u0647\u200c\u0633\u0627\u0632\u06cc \u0635\u062d\u06cc\u062d \u0628\u0631\u0648\u06a9\u0631\u0647\u0627\u060c Cruise Control \u0646\u06cc\u0627\u0632 \u062f\u0627\u0631\u062f \u06a9\u0647 \u0627\u0632 \u0645\u0634\u062e\u0635\u0627\u062a \u0633\u062e\u062a\u200c\u0627\u0641\u0632\u0627\u0631\u06cc \u0647\u0631 \u0628\u0631\u0648\u06a9\u0631 \u0622\u06af\u0627\u0647 \u0628\u0627\u0634\u062f. \u0627\u06cc\u0646 \u067e\u06cc\u06a9\u0631\u0628\u0646\u062f\u06cc \u062f\u0631 \u0641\u0627\u06cc\u0644\u06cc \u0628\u0647 \u0646\u0627\u0645 capacity.json \u06a9\u0647 \u062f\u0631 \u067e\u0648\u0634\u0647 config \u0642\u0631\u0627\u0631 \u062f\u0627\u0631\u062f \u0630\u062e\u06cc\u0631\u0647 \u0634\u062f\u0647 \u0627\u0633\u062a. \u0622\u0646 \u0631\u0627 \u0628\u0631\u0627\u06cc \u0648\u06cc\u0631\u0627\u06cc\u0634 \u0628\u0627\u0632 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
nano config\/capacity.json<\/span><\/div>\n
\u062f\u0631 \u062d\u0627\u0644\u062a \u067e\u06cc\u0634\u200c\u0641\u0631\u0636\u060c \u0641\u0627\u06cc\u0644 \u0628\u0647 \u0627\u06cc\u0646 \u0634\u06a9\u0644 \u0627\u0633\u062a:<\/span><\/div>\n
{<\/span><\/div>\n
\u00a0<\/span> “brokerCapacities”:[<\/span><\/div>\n
\u00a0 \u00a0 {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0<\/span> “brokerId”:<\/span> “-1”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0<\/span> “capacity”:<\/span> {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “DISK”:<\/span> “100000”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “CPU”:<\/span> “100”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “NW_IN”:<\/span> “10000”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “NW_OUT”:<\/span> “10000”<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 },<\/span><\/div>\n
\u00a0 \u00a0 \u00a0<\/span> “doc”:<\/span> “This<\/span> is the default capacity. Capacity unit used for disk is in MB, cpu is in percentage, network throughput is in KB.”<\/span><\/div>\n
\u00a0 \u00a0 },<\/span><\/div>\n
\u00a0 \u00a0 {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0<\/span> “brokerId”:<\/span> “0”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0<\/span> “capacity”:<\/span> {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “DISK”:<\/span> “500000”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “CPU”:<\/span> “100”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “NW_IN”:<\/span> “50000”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “NW_OUT”:<\/span> “50000”<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 },<\/span><\/div>\n
\u00a0 \u00a0 \u00a0<\/span> “doc”:<\/span> “This<\/span> overrides the capacity for broker 0.”<\/span><\/div>\n
\u00a0 \u00a0 }<\/span><\/div>\n
\u00a0 ]<\/span><\/div>\n
}<\/span><\/div>\n
\u0622\u0631\u0627\u06cc\u0647 brokerCapacities \u0634\u0627\u0645\u0644 \u0639\u0646\u0627\u0635\u0631\u06cc \u0627\u0633\u062a \u06a9\u0647 \u0628\u0647 \u0634\u0646\u0627\u0633\u0647\u200c\u0647\u0627\u06cc \u0628\u0631\u0648\u06a9\u0631 \u0645\u0631\u062a\u0628\u0637 \u0647\u0633\u062a\u0646\u062f. \u0647\u0631\u06a9\u062f\u0627\u0645 \u0634\u0627\u0645\u0644 \u0641\u06cc\u0644\u062f\u0647\u0627\u06cc\u06cc \u0628\u0631\u0627\u06cc \u0641\u0636\u0627\u06cc \u062f\u06cc\u0633\u06a9\u060c \u062a\u062e\u0635\u06cc\u0635 CPU \u0648 \u0627\u0632\u062f\u06cc\u0627\u062f \u0634\u0628\u06a9\u0647 \u0628\u0647 \u0648 \u0627\u0632 \u0628\u0631\u0648\u06a9\u0631 \u0627\u0633\u062a.<\/span><\/div>\n
\u0634\u0645\u0627 \u0633\u0647 \u0628\u0631\u0648\u06a9\u0631 Kafka \u0631\u0627 \u062f\u0631 \u0645\u0631\u0627\u062d\u0644 \u0642\u0628\u0644\u06cc \u0627\u0633\u062a\u0642\u0631\u0627\u0631 \u062f\u0627\u062f\u0647\u200c\u0627\u06cc\u062f. \u0641\u0627\u06cc\u0644 \u0631\u0627 \u0628\u0627 \u0627\u0641\u0632\u0648\u062f\u0646 \u0645\u0634\u062e\u0635\u0627\u062a \u0635\u062d\u06cc\u062d \u0628\u0631\u0627\u06cc \u0647\u0631 \u06cc\u06a9 \u0627\u0632 \u0622\u0646\u200c\u0647\u0627 \u062a\u063a\u06cc\u06cc\u0631 \u062f\u0647\u06cc\u062f:<\/span><\/div>\n
{<\/span><\/div>\n
\u00a0<\/span> “brokerCapacities”:[<\/span><\/div>\n
\u00a0 \u00a0 {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0<\/span> “brokerId”:<\/span> “-1”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0<\/span> “capacity”:<\/span> {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “DISK”:<\/span> “100000”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “CPU”:<\/span> “100”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “NW_IN”:<\/span> “10000”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “NW_OUT”:<\/span> “10000”<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 },<\/span><\/div>\n
\u00a0 \u00a0 \u00a0<\/span> “doc”:<\/span> “This<\/span> is the default capacity. Capacity unit used for disk is in MB, cpu is in percentage, network throughput is in KB.”<\/span><\/div>\n
\u00a0 \u00a0 },<\/span><\/div>\n
\u00a0 \u00a0 {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0<\/span> “brokerId”:<\/span> “1”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0<\/span> “capacity”:<\/span> {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “DISK”:<\/span> “100000”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “CPU”:<\/span> “100”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “NW_IN”:<\/span> “10000”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “NW_OUT”:<\/span> “10000”<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 },<\/span><\/div>\n
\u00a0 \u00a0 \u00a0<\/span> “doc”:<\/span> “”<\/span><\/div>\n
\u00a0 \u00a0 },<\/span><\/div>\n
\u00a0 \u00a0 {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0<\/span> “brokerId”:<\/span> “2”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0<\/span> “capacity”:<\/span> {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “DISK”:<\/span> “100000”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “CPU”:<\/span> “100”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “NW_IN”:<\/span> “10000”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “NW_OUT”:<\/span> “10000”<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 },<\/span><\/div>\n
\u00a0 \u00a0 \u00a0<\/span> “doc”:<\/span> “”<\/span><\/div>\n
\u00a0 \u00a0 },<\/span><\/div>\n
\u00a0 \u00a0 {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0<\/span> “brokerId”:<\/span> “3”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0<\/span> “capacity”:<\/span> {<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “DISK”:<\/span> “100000”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “CPU”:<\/span> “100”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “NW_IN”:<\/span> “10000”,<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0<\/span> “NW_OUT”:<\/span> “10000”<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 },<\/span><\/div>\n
\u00a0 \u00a0 \u00a0<\/span> “doc”:<\/span> “”<\/span><\/div>\n
\u00a0 \u00a0 }<\/span><\/div>\n
\u00a0 ]<\/span><\/div>\n
}<\/span><\/div>\n
\u0638\u0631\u0641\u06cc\u062a\u200c\u0647\u0627\u06cc \u062f\u06cc\u0633\u06a9 \u0631\u0627 \u0637\u0628\u0642 \u0627\u0646\u062f\u0627\u0632\u0647 Droplet\u200c\u0647\u0627\u06cc \u062e\u0648\u062f \u062a\u0646\u0638\u06cc\u0645 \u06a9\u0646\u06cc\u062f\u060c \u0633\u067e\u0633 \u0641\u0627\u06cc\u0644 \u0631\u0627 \u0630\u062e\u06cc\u0631\u0647 \u0648 \u0628\u0633\u062a\u0647 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
\u062f\u0631 \u0627\u062f\u0627\u0645\u0647\u060c Cruise Control \u0631\u0627 \u067e\u06cc\u06a9\u0631\u0628\u0646\u062f\u06cc \u0645\u06cc\u200c\u06a9\u0646\u06cc\u062f \u062a\u0627 \u0628\u0647 \u06a9\u0644\u0627\u0633\u062a\u0631 Kafka \u0634\u0645\u0627 \u062f\u0631 \u062d\u0627\u0644\u062a KRaft \u0645\u062a\u0635\u0644 \u0634\u0648\u062f. \u0628\u0627\u06cc\u062f \u0641\u0627\u06cc\u0644 cruisecontrol.properties \u0631\u0627 \u062f\u0631 \u067e\u0648\u0634\u0647 config \u0648\u06cc\u0631\u0627\u06cc\u0634 \u06a9\u0646\u06cc\u062f. \u0628\u0631\u0627\u06cc \u0628\u0627\u0632 \u06a9\u0631\u062f\u0646 \u0622\u0646 \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u0631\u0627 \u0627\u062c\u0631\u0627 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
nano config\/cruisecontrol.properties<\/span><\/div>\n
\u062e\u0637\u0648\u0637 \u0632\u06cc\u0631 \u0631\u0627 \u067e\u06cc\u062f\u0627 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
# The Kafka cluster to control.<\/span><\/div>\n
bootstrap.servers=localhost:9092<\/span><\/div>\n
\u067e\u0627\u0631\u0627\u0645\u062a\u0631 bootstrap.servers \u0645\u0634\u062e\u0635 \u0645\u06cc\u200c\u06a9\u0646\u062f Cruise Control \u0628\u0647 \u06a9\u062f\u0627\u0645 \u0628\u0631\u0648\u06a9\u0631 Kafka<\/span> (\u0648<\/span> \u062f\u0631 \u0646\u062a\u06cc\u062c\u0647 \u06a9\u062f\u0627\u0645 \u06a9\u0644\u0627\u0633\u062a\u0631) \u0645\u062a\u0635\u0644 \u0634\u0648\u062f. \u0622\u0646 \u0631\u0627 \u0628\u0647 \u0634\u06a9\u0644 \u0632\u06cc\u0631 \u062a\u063a\u06cc\u06cc\u0631 \u062f\u0647\u06cc\u062f:<\/span><\/div>\n
# The Kafka cluster to control.<\/span><\/div>\n
bootstrap.servers=kafka1.your_domain:9092<\/span><\/div>\n
<\/div>\n
# Switch to KRaft mode<\/span><\/div>\n
kafka.broker.failure.detection.enable=true<\/span><\/div>\n
\u067e\u0627\u0631\u0627\u0645\u062a\u0631 kafka.broker.failure.detection.enable=true \u0628\u0647 Cruise Control \u0645\u06cc\u200c\u06af\u0648\u06cc\u062f \u06a9\u0647 \u062a\u0646\u0638\u06cc\u0645\u0627\u062a ZooKeeper \u0631\u0627 \u0646\u0627\u062f\u06cc\u062f\u0647 \u0628\u06af\u06cc\u0631\u062f \u0648 \u0628\u0647\u200c\u0635\u0648\u0631\u062a \u0628\u0648\u0645\u06cc \u0627\u0632 \u062d\u0627\u0644\u062a KRaft \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u06a9\u0646\u062f. \u0639\u0628\u0627\u0631\u062a kafka1.your_domain \u0631\u0627 \u0628\u0627 \u0646\u0627\u0645 \u062f\u0627\u0645\u0646\u0647 \u06cc\u0627 \u0622\u062f\u0631\u0633 \u0628\u0631\u0648\u06a9\u0631 Kafka \u062e\u0648\u062f \u062c\u0627\u06cc\u06af\u0632\u06cc\u0646 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
\u0633\u067e\u0633 \u062e\u0637\u0648\u0637 \u0632\u06cc\u0631 \u0631\u0627 \u067e\u06cc\u062f\u0627 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
# The configuration for the BrokerCapacityConfigFileResolver<\/span> (supports<\/span> JBOD, non-JBOD, and heterogeneous CPU core capacities)<\/span><\/div>\n
#capacity<\/a><\/span>.config.file=config\/capacity.json<\/span><\/div>\n
capacity.config.file=config\/capacityJBOD.json<\/span><\/div>\n
\u0648 \u0622\u0646\u200c\u0647\u0627 \u0631\u0627 \u0628\u0647 \u0634\u06a9\u0644 \u0632\u06cc\u0631 \u062a\u063a\u06cc\u06cc\u0631 \u062f\u0647\u06cc\u062f \u062a\u0627 \u0641\u0627\u06cc\u0644 \u067e\u06cc\u06a9\u0631\u0628\u0646\u062f\u06cc \u0627\u0635\u0644\u06cc \u0638\u0631\u0641\u06cc\u062a\u200c\u0647\u0627 \u0641\u0639\u0627\u0644 \u0634\u0648\u062f:<\/span><\/div>\n
# The configuration for the BrokerCapacityConfigFileResolver<\/span> (supports<\/span> JBOD, non-JBOD, and heterogeneous CPU core capacities)<\/span><\/div>\n
capacity.config.file=config\/capacity.json<\/span><\/div>\n
#capacity<\/a><\/span>.config.file=config\/capacityJBOD.json<\/span><\/div>\n
\u062f\u0631 \u0627\u06cc\u0646\u062c\u0627\u060c \u0641\u0627\u06cc\u0644 capacity.json<\/span> (\u0648\u0627\u0642\u0639<\/span> \u062f\u0631 \u067e\u0648\u0634\u0647 config\/) \u0628\u0647 \u0639\u0646\u0648\u0627\u0646 \u0645\u0631\u062c\u0639 \u0638\u0631\u0641\u06cc\u062a \u0628\u0631\u0648\u06a9\u0631\u0647\u0627 \u062a\u0646\u0638\u06cc\u0645 \u0634\u062f\u0647 \u0627\u0633\u062a.<\/span><\/div>\n
<\/div>\n
\u067e\u0633 \u0627\u0632 \u0627\u062a\u0645\u0627\u0645\u060c \u0641\u0627\u06cc\u0644 \u0631\u0627 \u0630\u062e\u06cc\u0631\u0647 \u06a9\u0631\u062f\u0647 \u0648 \u0628\u0628\u0646\u062f\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
\u0627\u06a9\u0646\u0648\u0646 \u06a9\u0647 Cruise Control \u067e\u06cc\u06a9\u0631\u0628\u0646\u062f\u06cc \u0634\u062f\u0647 \u0627\u0633\u062a\u060c \u0622\u0646 \u0631\u0627 \u062f\u0631 \u06cc\u06a9 \u062a\u0631\u0645\u06cc\u0646\u0627\u0644 \u062c\u062f\u0627\u06af\u0627\u0646\u0647 \u0628\u0627 \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u0627\u062c\u0631\u0627 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
.\/kafka-cruise-control-start.sh config\/cruisecontrol.properties<\/span><\/div>\n
\u067e\u0633 \u0627\u0632 \u0627\u062c\u0631\u0627\u06cc \u062f\u0633\u062a\u0648\u0631\u060c \u062e\u0631\u0648\u062c\u06cc\u200c\u0647\u0627\u06cc \u0645\u062a\u0639\u062f\u062f\u06cc \u062f\u0631 \u062a\u0631\u0645\u06cc\u0646\u0627\u0644 \u0646\u0645\u0627\u06cc\u0634 \u062f\u0627\u062f\u0647 \u062e\u0648\u0627\u0647\u062f \u0634\u062f\u060c \u0686\u0631\u0627 \u06a9\u0647 Cruise Control \u0628\u0647\u200c\u0635\u0648\u0631\u062a \u0645\u062f\u0627\u0648\u0645 \u06a9\u0644\u0627\u0633\u062a\u0631 Kafka \u0634\u0645\u0627 \u0631\u0627 \u0646\u0638\u0627\u0631\u062a \u0648 \u0628\u0647\u06cc\u0646\u0647\u200c\u0633\u0627\u0632\u06cc \u0645\u06cc\u200c\u06a9\u0646\u062f.<\/span><\/div>\n
\u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 Cruise Control CLI<\/span><\/div>\n
<\/div>\n
Cruise Control \u06cc\u06a9 API \u0645\u0628\u062a\u0646\u06cc \u0628\u0631 REST \u0631\u0648\u06cc \u067e\u0648\u0631\u062a \u06f9\u06f0\u06f9\u06f0 \u0627\u0631\u0627\u0626\u0647 \u0645\u06cc\u200c\u062f\u0647\u062f \u06a9\u0647 \u0628\u0631\u0627\u06cc \u067e\u06cc\u06a9\u0631\u0628\u0646\u062f\u06cc \u0648 \u06a9\u0627\u0631\u0647\u0627\u06cc \u0645\u062f\u06cc\u0631\u06cc\u062a\u06cc \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0645\u06cc\u200c\u0634\u0648\u062f. \u0627\u0645\u0627 \u067e\u0631\u0648\u0698\u0647\u200c\u06cc Cruise Control \u06cc\u06a9 \u0627\u0628\u0632\u0627\u0631 \u062e\u0637 \u0641\u0631\u0645\u0627\u0646 \u0628\u0647 \u0646\u0627\u0645 cccli \u0646\u06cc\u0632 \u062f\u0627\u0631\u062f \u06a9\u0647 \u0628\u0627 \u0632\u0628\u0627\u0646 Python \u0646\u0648\u0634\u062a\u0647 \u0634\u062f\u0647 \u0648 \u0628\u0647\u200c\u0635\u0648\u0631\u062a \u0633\u0627\u062f\u0647\u200c\u062a\u0631\u060c \u0627\u06cc\u0646 API \u0631\u0627 \u062f\u0631 \u0642\u0627\u0644\u0628 \u062f\u0633\u062a\u0648\u0631\u0627\u062a \u062a\u0631\u0645\u06cc\u0646\u0627\u0644 \u062f\u0631 \u0627\u062e\u062a\u06cc\u0627\u0631 \u0634\u0645\u0627 \u0642\u0631\u0627\u0631 \u0645\u06cc\u200c\u062f\u0647\u062f.<\/span><\/div>\n
<\/div>\n
\u0641\u0639\u0627\u0644\u200c\u0633\u0627\u0632\u06cc \u0645\u062d\u06cc\u0637 \u0645\u062c\u0627\u0632\u06cc \u067e\u0627\u06cc\u062a\u0648\u0646<\/span><\/div>\n
<\/div>\n
\u0627\u0628\u062a\u062f\u0627 \u0648\u0627\u0631\u062f \u0645\u062d\u06cc\u0637 \u0645\u062c\u0627\u0632\u06cc \u067e\u0627\u06cc\u062a\u0648\u0646\u06cc \u0634\u0648\u06cc\u062f \u06a9\u0647 \u062f\u0631 \u0645\u0631\u0627\u062d\u0644 \u0642\u0628\u0644\u06cc \u0627\u06cc\u062c\u0627\u062f \u06a9\u0631\u062f\u0647\u200c\u0627\u06cc\u062f:<\/span><\/div>\n
cd ~\/venv<\/span><\/div>\n
\u0628\u0627 \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u0645\u062d\u06cc\u0637 \u0645\u062c\u0627\u0632\u06cc \u0631\u0627 \u0641\u0639\u0627\u0644 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
.\/bin\/activate<\/span><\/div>\n
\u0633\u067e\u0633 \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 pip\u060c \u0627\u0628\u0632\u0627\u0631 Cruise Control CLI \u0631\u0627 \u0646\u0635\u0628 \u06a9\u0646\u06cc\u062f:<\/span><\/div>\n
pip install cruise-control-client<\/span><\/div>\n
\u062e\u0631\u0648\u062c\u06cc \u0646\u0647\u0627\u06cc\u06cc \u0686\u06cc\u0632\u06cc \u0634\u0628\u06cc\u0647 \u0628\u0647 \u0627\u06cc\u0646 \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f:<\/span><\/div>\n
Installing collected packages: urllib3, idna, charset-normalizer, certifi, requests, cruise-control-client<\/span><\/div>\n
Successfully installed …<\/span><\/div>\n
\u0628\u0627 \u0627\u06cc\u0646 \u0646\u0635\u0628\u060c \u062f\u0633\u062a\u0648\u0631 cccli \u062f\u0631 \u062a\u0631\u0645\u06cc\u0646\u0627\u0644 \u062f\u0631 \u062f\u0633\u062a\u0631\u0633 \u0642\u0631\u0627\u0631 \u0645\u06cc\u200c\u06af\u06cc\u0631\u062f.<\/span><\/div>\n
<\/div>\n
\u0645\u0634\u0627\u0647\u062f\u0647\u200c\u06cc \u0648\u0636\u0639\u06cc\u062a \u0641\u0639\u0644\u06cc \u06a9\u0644\u0627\u0633\u062a\u0631 Kafka<\/span><\/div>\n
<\/div>\n
\u0628\u0631\u0627\u06cc \u0645\u0634\u0627\u0647\u062f\u0647 \u0627\u0637\u0644\u0627\u0639\u0627\u062a \u0645\u0631\u0628\u0648\u0637 \u0628\u0647 \u0648\u0636\u0639\u06cc\u062a \u0628\u0627\u0631<\/span> (load)<\/span> \u0641\u0639\u0644\u06cc \u06a9\u0644\u0627\u0633\u062a\u0631 Kafka\u060c \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u0631\u0627 \u0627\u062c\u0631\u0627 \u06a9\u0646\u06cc\u062f<\/span> (\u0628\u0647<\/span> \u062c\u0627\u06cc localhost:9090 \u0622\u062f\u0631\u0633 Cruise Control \u062e\u0648\u062f \u0631\u0627 \u0642\u0631\u0627\u0631 \u062f\u0647\u06cc\u062f):<\/span><\/div>\n
cccli<\/span> -a<\/span> localhost:9090 load<\/span><\/div>\n
\u062e\u0631\u0648\u062c\u06cc \u0634\u0627\u0645\u0644 \u0627\u0637\u0644\u0627\u0639\u0627\u062a\u06cc \u0645\u0627\u0646\u0646\u062f \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 \u062f\u06cc\u0633\u06a9\u060c \u067e\u0631\u062f\u0627\u0632\u0646\u062f\u0647\u060c \u067e\u0647\u0646\u0627\u06cc \u0628\u0627\u0646\u062f \u0634\u0628\u06a9\u0647\u060c \u062a\u0639\u062f\u0627\u062f \u0644\u06cc\u062f\u0631\u0647\u0627 \u0648 \u063a\u06cc\u0631\u0647 \u0628\u0631\u0627\u06cc \u0647\u0631 \u0628\u0631\u0648\u06a9\u0631 \u0627\u0633\u062a:<\/span><\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 HOST \u00a0 \u00a0 \u00a0 \u00a0 BROKER \u00a0 \u00a0 \u00a0 … \u00a0 \u00a0 \u00a0 CPU(%) \u00a0 \u00a0 \u00a0 NW_IN_CAP \u00a0 \u00a0 \u00a0 …<\/span><\/div>\n
kafka1.your_domain \u00a0 \u00a01 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0… \u00a0 \u00a0 \u00a0 \u00a0 0.999 \u00a0 \u00a0 \u00a0 \u00a0 10000.000 \u00a0 \u00a0 \u00a0 …<\/span><\/div>\n
…<\/span><\/div>\n
\u0641\u0639\u0627\u0644\u200c\u0633\u0627\u0632\u06cc \u062a\u0639\u0645\u06cc\u0631 \u062e\u0648\u062f\u06a9\u0627\u0631<\/span> (Self-Healing)<\/span><\/div>\n
<\/div>\n
Cruise Control \u0642\u0627\u0628\u0644\u06cc\u062a<\/span> \u00ab\u062a\u0639\u0645\u06cc\u0631<\/span> \u062e\u0648\u062f\u06a9\u0627\u0631\u00bb \u062f\u0627\u0631\u062f\u061b \u06cc\u0639\u0646\u06cc \u062f\u0631 \u0635\u0648\u0631\u062a \u062e\u0631\u0627\u0628\u06cc \u0628\u0631\u0648\u06a9\u0631 \u06cc\u0627 \u0646\u0642\u0636 \u0647\u062f\u0641\u200c\u0647\u0627\u06cc \u0645\u0634\u062e\u0635\u200c\u0634\u062f\u0647<\/span> (Goals)\u060c<\/span> \u062e\u0648\u062f\u0634 \u0628\u0647 \u0635\u0648\u0631\u062a \u062e\u0648\u062f\u06a9\u0627\u0631 \u0648\u0636\u0639\u06cc\u062a \u0631\u0627 \u0627\u0635\u0644\u0627\u062d \u0645\u06cc\u200c\u06a9\u0646\u062f. \u0628\u0631\u0627\u06cc \u0641\u0639\u0627\u0644\u200c\u0633\u0627\u0632\u06cc \u0627\u06cc\u0646 \u0648\u06cc\u0698\u06af\u06cc \u062f\u0631 \u0632\u0645\u0627\u0646 \u062e\u0631\u0627\u0628\u06cc \u0628\u0631\u0648\u06a9\u0631\u060c \u062f\u0633\u062a\u0648\u0631 \u0632\u06cc\u0631 \u0631\u0627 \u0628\u0632\u0646\u06cc\u062f:<\/span><\/div>\n
cccli<\/span> -a<\/span> localhost:9090 admin<\/span> –enable-self-healing-for<\/span> broker_failure<\/span><\/div>\n
\u062e\u0631\u0648\u062c\u06cc \u0628\u0647 \u0635\u0648\u0631\u062a \u0632\u06cc\u0631 \u062e\u0648\u0627\u0647\u062f \u0628\u0648\u062f \u0648 \u0646\u0634\u0627\u0646 \u0645\u06cc\u200c\u062f\u0647\u062f \u06a9\u0647 \u062a\u0646\u0638\u06cc\u0645\u0627\u062a \u062a\u063a\u06cc\u06cc\u0631 \u06a9\u0631\u062f\u0647\u200c\u0627\u0646\u062f:<\/span><\/div>\n
{<\/span><\/div>\n
\u00a0 selfHealingEnabledBefore: {BROKER_FAILURE=false},<\/span><\/div>\n
\u00a0 selfHealingEnabledAfter: {BROKER_FAILURE=true}<\/span><\/div>\n
}<\/span><\/div>\n
<\/div>\n
\u0646\u062a\u06cc\u062c\u0647\u200c\u06af\u06cc\u0631\u06cc<\/span><\/div>\n
<\/div>\n
\u062f\u0631 \u0627\u06cc\u0646 \u0645\u0631\u062d\u0644\u0647\u060c \u0634\u0645\u0627:<\/span><\/div>\n
\u2022 \u0645\u062a\u0631\u06cc\u06a9\u200c\u0631\u06cc\u067e\u0648\u0631\u062a\u0631 Cruise Control \u0631\u0627 \u0631\u0648\u06cc \u0647\u0631 \u0646\u0648\u062f Kafka \u0646\u0635\u0628 \u06a9\u0631\u062f\u06cc\u062f.<\/span><\/div>\n
\u2022 \u0641\u0627\u06cc\u0644\u200c\u0647\u0627\u06cc \u067e\u06cc\u06a9\u0631\u0628\u0646\u062f\u06cc \u0631\u0627 \u0648\u06cc\u0631\u0627\u06cc\u0634 \u0648 Cruise Control \u0631\u0627 \u0627\u062c\u0631\u0627 \u06a9\u0631\u062f\u06cc\u062f.<\/span><\/div>\n
\u2022 \u0627\u0628\u0632\u0627\u0631 cccli \u0631\u0627 \u0646\u0635\u0628 \u06a9\u0631\u062f\u06cc\u062f \u0648 \u0646\u062d\u0648\u0647\u200c\u06cc \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 \u0622\u0646 \u0628\u0631\u0627\u06cc \u0645\u0627\u0646\u06cc\u062a\u0648\u0631\u06cc\u0646\u06af \u0648 \u0645\u062f\u06cc\u0631\u06cc\u062a \u06a9\u0644\u0627\u0633\u062a\u0631 Kafka \u0631\u0627 \u06cc\u0627\u062f \u06af\u0631\u0641\u062a\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
\u0628\u0631\u0627\u06cc \u0627\u0637\u0644\u0627\u0639\u0627\u062a \u0628\u06cc\u0634\u062a\u0631\u060c \u0645\u06cc\u200c\u062a\u0648\u0627\u0646\u06cc\u062f \u0628\u0647 \u0645\u0633\u062a\u0646\u062f\u0627\u062a \u0631\u0633\u0645\u06cc Cruise Control \u0645\u0631\u0627\u062c\u0639\u0647 \u06a9\u0646\u06cc\u062f.<\/span><\/div>\n
<\/div>\n
\u0627\u06a9\u0646\u0648\u0646 \u0634\u0645\u0627 \u062a\u0648\u0627\u0646\u0627\u06cc\u06cc \u0645\u062f\u06cc\u0631\u06cc\u062a \u06a9\u0644\u0627\u0633\u062a\u0631 Kafka \u0631\u0627 \u0627\u0632 \u0637\u0631\u06cc\u0642 \u06a9\u062f \u0628\u0627 \u0627\u0633\u062a\u0641\u0627\u062f\u0647 \u0627\u0632 KafkaAdminClient \u0648 \u0627\u0628\u0632\u0627\u0631\u0647\u0627\u06cc \u062c\u0627\u0646\u0628\u06cc \u0645\u0627\u0646\u0646\u062f kcat \u0648 Cruise Control \u062f\u0627\u0631\u06cc\u062f.<\/span><\/div>\n
<\/div>","protected":false},"excerpt":{"rendered":"

\u0645\u0642\u062f\u0645\u0647 Apache Kafka \u06cc\u06a9 \u067e\u0644\u062a\u0641\u0631\u0645 \u067e\u0631\u062f\u0627\u0632\u0634 \u0631\u0648\u06cc\u062f\u0627\u062f \u0648 \u062c\u0631\u06cc\u0627\u0646 \u062a\u0648\u0632\u06cc\u0639\u200c\u0634\u062f\u0647 \u0648 \u0645\u062a\u0646\u200c\u0628\u0627\u0632 \u0627\u0633\u062a \u06a9\u0647 \u0628\u0627 \u0632\u0628\u0627\u0646 \u062c\u0627\u0648\u0627 \u0646\u0648\u0634\u062a\u0647 \u0634\u062f\u0647 \u0627\u0633\u062a. \u0627\u06cc\u0646 \u067e\u0644\u062a\u0641\u0631\u0645 \u0628\u0631\u0627\u06cc \u067e\u0631\u062f\u0627\u0632\u0634 \u062f\u0627\u062f\u0647\u200c\u0647\u0627\u06cc \u0632\u0645\u0627\u0646 \u0648\u0627\u0642\u0639\u06cc \u06a9\u0647 \u0646\u06cc\u0627\u0632 \u0628\u0647 \u0645\u0646\u0627\u0628\u0639 \u0632\u06cc\u0627\u062f\u06cc \u062f\u0627\u0631\u0646\u062f \u0637\u0631\u0627\u062d\u06cc \u0634\u062f\u0647 \u0627\u0633\u062a \u0648 \u0628\u0647\u200c\u0637\u0648\u0631 \u0630\u0627\u062a\u06cc \u0645\u0642\u06cc\u0627\u0633\u200c\u067e\u0630\u06cc\u0631 \u0627\u0633\u062a \u0648 \u0627\u0632 \u0637\u0631\u06cc\u0642 \u062a\u0648\u0627\u0646 \u0639\u0645\u0644\u06cc\u0627\u062a\u06cc \u0648 \u062f\u0631 \u062f\u0633\u062a\u0631\u0633 \u0628\u0648\u062f\u0646 \u0628\u0627\u0644\u0627 \u0628\u0647\u0631\u0647 \u0645\u06cc\u200c\u0628\u0631\u062f. \u0627\u06cc\u0646 \u067e\u0631\u0648\u0698\u0647 […]<\/p>\n","protected":false},"author":1,"featured_media":5396,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"om_disable_all_campaigns":false,"_monsterinsights_skip_tracking":false,"yasr_overall_rating":0,"yasr_post_is_review":"","yasr_auto_insert_disabled":"","yasr_review_type":"","footnotes":""},"categories":[131],"tags":[420,422,421],"class_list":["post-5394","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-131","tag-apache-kafka","tag-422","tag-421"],"aioseo_notices":[],"yasr_visitor_votes":{"stars_attributes":{"read_only":false,"span_bottom":false},"number_of_votes":0,"sum_votes":0},"_links":{"self":[{"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/posts\/5394","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/comments?post=5394"}],"version-history":[{"count":3,"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/posts\/5394\/revisions"}],"predecessor-version":[{"id":5399,"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/posts\/5394\/revisions\/5399"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/media\/5396"}],"wp:attachment":[{"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/media?parent=5394"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/categories?post=5394"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/parmin.cloud\/blog\/wp-json\/wp\/v2\/tags?post=5394"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}