{"id":10264,"date":"2024-04-14T17:53:34","date_gmt":"2024-04-14T09:53:34","guid":{"rendered":"https:\/\/egonlin.com\/?p=10264"},"modified":"2024-04-14T18:01:27","modified_gmt":"2024-04-14T10:01:27","slug":"%e4%ba%8c%e3%80%81kafka%e5%b8%b8%e7%94%a8%e7%9a%84shell%e5%91%bd%e4%bb%a4","status":"publish","type":"post","link":"https:\/\/egonlin.com\/?p=10264","title":{"rendered":"\u4e8c\u3001kafka\u5e38\u7528\u7684shell\u547d\u4ee4"},"content":{"rendered":"<p>1\u3001\u521b\u5efatopic<\/p>\n<pre>bin\/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test<\/pre>\n<p>2\u3001\u67e5\u770b\u521b\u5efa\u7684topic<\/p>\n<pre>bin\/kafka-topics.sh --list --zookeeper localhost:2181<\/pre>\n<p>3\u3001\u751f\u4ea7\u8005\u53d1\u5e03\u6d88\u606f\u547d\u4ee4<\/p>\n<pre>\uff08\u6267\u884c\u5b8c\u6b64\u547d\u4ee4\u540e\uff0c\u5728\u63a7\u5236\u53f0\u8f93\u5165\u8981\u53d1\u9001\u7684\u6d88\u606f\uff0c\u56de\u8f66\u5373\u53ef\uff09\r\n\r\nbin\/kafka-console-producer.sh --broker-list 192.168.91.231:9092,192.168.91.231:9093,192.168.91.231:9094 --topic test<\/pre>\n<p>4\u3001\u6d88\u8d39\u8005\u63a5\u53d7\u6d88\u606f\u547d\u4ee4<\/p>\n<pre>bin\/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning<\/pre>\n<p>5\u3001kafka\u542f\u52a8<\/p>\n<pre data-index=\"2\">\u9996\u5148\u542f\u52a8<a href=\"https:\/\/so.csdn.net\/so\/search?q=zookeeper&amp;spm=1001.2101.3001.7020\" target=\"_blank\" rel=\"noopener\" data-report-click=\"{&quot;spm&quot;:&quot;1001.2101.3001.7020&quot;,&quot;dest&quot;:&quot;https:\/\/so.csdn.net\/so\/search?q=zookeeper&amp;spm=1001.2101.3001.7020&quot;,&quot;extra&quot;:&quot;{\\&quot;searchword\\&quot;:\\&quot;zookeeper\\&quot;}&quot;}\" data-tit=\"zookeeper\" data-pretit=\"zookeeper\">zookeeper<\/a>\u00a0zkServer.sh start\uff08\u76f8\u5f53\u4e8e\u4e00\u4e2aserver,kafka\u4f1a\u8fde\u63a5\u8fd9\u4e2aserver\uff09\r\nbin\/kafka-server-start.sh config\/server.properties  # \u542f\u52a8kafka<\/pre>\n<p>6\u3001\u67e5\u770bkafka\u8282\u70b9\u6570\u76ee<\/p>\n<pre>\u5728zookeeper\u4e2d\u67e5\u770b\uff0c\u767b\u5f55\u5ba2\u6237\u7aefbin\/zkCli.sh \u6267\u884cls \/brokers\/ids\u00a0\u67e5\u770b\u8282\u70b9\u6570\u76ee\u53ca\u8282\u70b9ID\uff0c[0, 1, 2]<\/pre>\n<p>7\u3001kafka\u4e2d\u7684\u6982\u5ff5<\/p>\n<pre>\u751f\u4ea7\u8005 Producer\u3001\u4ee3\u7406 Broker\u3001\u6d88\u8d39\u8005 Consumer\u3001\u4e3b\u9898 Topic\u3001\u5206\u533a Partition\u3001\u6d88\u8d39\u8005\u7ec4 Consumer Group<\/pre>\n<p>8\u3001\u67e5\u770b\u4e3b\u9898\u4fe1\u606f<\/p>\n<pre>bin\/kafka-topics.sh --zookeeper 192.168.91.231:2181 [\u52a0\u5176\u4ed6\u9009\u9879]\r\n\r\neg:\r\n\r\nbin\/kafka-topics.sh --zookeeper 192.168.91.231:2181 --describe \r\nbin\/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test<\/pre>\n<p>9\u3001\u4e3a\u4e3b\u9898\u521b\u5efa\u5206\u533a<\/p>\n<pre>\u4e00\u5171\u521b\u5efa\u516b\u4e2a\u5206\u533a\uff0c\u7f16\u53f7\u5206\u522b\u4e3a0~7\r\nbin\/kafka-topics.sh --zookeeper 192.168.91.231:2181 --alter -partitions 8 -topic test<\/pre>\n<p>10\u3001\u67e5\u770bkafka\u8fdb\u7a0b<\/p>\n<pre>ps -ef|grep server.properties \r\nps -ef|grep server-1.properties \r\nps -ef|grep server-2.properties<\/pre>\n<p>11\u3001kafka\u5b95\u673a\u91cd\u542f\u540e\uff0c\u6d88\u606f\u4e0d\u4f1a\u4e22\u5931<\/p>\n<p>12\u3001kafka\u5176\u4e2d\u4e00\u4e2abroker\u5b95\u673a\u540e\uff0c\u5bf9\u6d88\u8d39\u8005\u548c\u751f\u4ea7\u8005\u5f71\u54cd\u5f88\u5c0f\uff08\u547d\u4ee4\u884c\u4e0b\u6d4b\u8bd5\uff09<\/p>\n<pre>\u6d88\u8d39\u8005\u4f1a\u5c1d\u8bd5\u8fde\u63a5\uff0c\u8fde\u63a5\u4e0d\u5230\uff0c\u8fd4\u56dejava.net.ConnectException: Connection refused\u5f02\u5e38 \u751f\u4ea7\u8005\u53ef\u80fd\u4f1a\u5728\u53d1\u9001\u6d88\u606f\u7684\u65f6\u5019\u62a5\u5f02\u5e38\uff0c\u4f46\u4f1a\u5f88\u5feb\u8fde\u63a5\u5230\u5176\u4ed6broker\uff0c\u7ee7\u7eed\u6b63\u5e38\u4f7f\u7528<\/pre>\n<p>13. \u67e5\u770bkafka\u6d88\u606f\u961f\u5217\u7684\u79ef\u538b\u60c5\u51b5<\/p>\n<pre data-index=\"9\">bin\/kafka-consumer-groups.sh --zookeeper 192.168.91.231:2181 --describe --group console-consumer-37289<\/pre>\n<p>14. kafka \u4e2d\u67e5\u770b\u6240\u6709\u7684group\u5217\u8868\u4fe1\u606f<\/p>\n<pre data-index=\"10\"> bin\/kafka-consumer-groups.sh --zookeeper 192.168.91.231:2181 --list\r\n<\/pre>\n","protected":false},"excerpt":{"rendered":"<p>1\u3001\u521b\u5efatopic bin\/kafka-topics.sh &#8211;create &#8211;zookeeper loca [&hellip;]<\/p>\n","protected":false},"author":3,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":[],"categories":[454],"tags":[],"_links":{"self":[{"href":"https:\/\/egonlin.com\/index.php?rest_route=\/wp\/v2\/posts\/10264"}],"collection":[{"href":"https:\/\/egonlin.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/egonlin.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/egonlin.com\/index.php?rest_route=\/wp\/v2\/users\/3"}],"replies":[{"embeddable":true,"href":"https:\/\/egonlin.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=10264"}],"version-history":[{"count":6,"href":"https:\/\/egonlin.com\/index.php?rest_route=\/wp\/v2\/posts\/10264\/revisions"}],"predecessor-version":[{"id":10270,"href":"https:\/\/egonlin.com\/index.php?rest_route=\/wp\/v2\/posts\/10264\/revisions\/10270"}],"wp:attachment":[{"href":"https:\/\/egonlin.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=10264"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/egonlin.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=10264"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/egonlin.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=10264"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}