{"id":505,"date":"2021-07-13T10:17:53","date_gmt":"2021-07-13T02:17:53","guid":{"rendered":"https:\/\/22pig.com\/?p=505"},"modified":"2021-07-13T10:17:53","modified_gmt":"2021-07-13T02:17:53","slug":"kafka-%e5%b8%b8%e7%94%a8%e6%9f%a5%e7%9c%8b%e5%91%bd%e4%bb%a4","status":"publish","type":"post","link":"http:\/\/22pig.com\/?p=505","title":{"rendered":"kafka \u5e38\u7528\u67e5\u770b\u547d\u4ee4"},"content":{"rendered":"<h4>\u67e5\u770btopic<\/h4>\n<pre class=\" language-shell\"><code class=\"prism language-shell\">bin\/kafka-topics.sh \\\n--zookeeper emr-header-1:2181,emr-header-2:2181,emr-header-3:2181\/kafka-1.0.1 \\\n--list\n<\/code><\/pre>\n<h4><a id=\"kafkatopic_7\"><\/a>\u67e5\u770bkafka\u7684topic\u8be6\u7ec6\u4fe1\u606f<\/h4>\n<pre class=\" language-shell\"><code class=\"prism language-shell\">bin\/kafka-topics.sh \\\n--zookeeper emr-header-1:2181,emr-header-2:2181,emr-header-3:2181\/kafka-1.0.1 \\\n--topic T1 \\\n--describe\n<\/code><\/pre>\n<h4><a id=\"_16\"><\/a>\u67e5\u770b\u6d88\u8d39\u8005\u7ec4<\/h4>\n<pre class=\" language-shell\"><code class=\"prism language-shell\">bin\/kafka-consumer-groups.sh \\\n--bootstrap-server 172.1.2.3:9092,172.1.2.4:9092,172.1.2.5:9092 \\\n--list\n<\/code><\/pre>\n<h4><a id=\"_24\"><\/a>\u67e5\u770b\u6d88\u8d39\u8005\u7ec4\u8be6\u60c5<\/h4>\n<pre class=\" language-shell\"><code class=\"prism language-shell\">bin\/kafka-consumer-groups.sh \\\n--bootstrap-server 172.1.2.3:9092,172.1.2.4:9092,172.1.2.5:9092 \\\n--group group_name1 \\\n--describe\n<\/code><\/pre>\n<h4><a id=\"__consumer_offsets_33\"><\/a>\u67e5\u770b__consumer_offsets\u4e2d\u8bb0\u8f7d\u7684\u504f\u79fb\u91cf\u6570\u636e<\/h4>\n<pre class=\" language-shell\"><code class=\"prism language-shell\">bin\/kafka-console-consumer.sh --topic __consumer_offsets \\\n--bootstrap-server 172.1.2.3:9092,172.1.2.4:9092,172.1.2.5:9092 \\\n--formatter <span class=\"token string\">\"kafka.coordinator.group.GroupMetadataManager\\<span class=\"token variable\">$OffsetsMessageFormatter<\/span>\"<\/span> \\\n--consumer.config config\/consumer.properties \\\n--from-beginning <span class=\"token operator\">|<\/span> <span class=\"token function\">grep<\/span> group_name1 \n<\/code><\/pre>\n<h4><a id=\"topic5_43\"><\/a>\u67e5\u770btopic\u4fe1\u606f\u6700\u8fd15\u6761<\/h4>\n<pre class=\" language-shell\"><code class=\"prism language-shell\">bin\/kafka-console-consumer.sh \\\n--zookeeper emr-header-1:2181,emr-header-2:2181,emr-header-3:2181\/kafka-1.0.1 \\\n--topic T2 \\\n--max-messages 5\n<\/code><\/pre>\n<h4><a id=\"_51\"><\/a>\u6307\u5b9a\u6d88\u8d39\u8005\u7ec4\u6d88\u8d39\u4e3b\u9898\u6570\u636e\uff1a<\/h4>\n<pre class=\" language-shell\"><code class=\"prism language-shell\">bin\/kafka-console-consumer.sh \\\n--bootstrap-server 172.1.2.3:9092,172.1.2.4:9092,172.1.2.5:9092 \\\n--topic T2 --group group_name1<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"<p>\u67e5\u770btopic bin\/kafka-topics.sh \\ &#8211;zookeeper emr-header-1:2181,emr-header-2:2181,emr-header-3:2181\/kafka-1.0.1 \\ &#8211;list \u67e5\u770bkafka\u7684topic\u8be6\u7ec6\u4fe1\u606f bin\/kafka-topics.sh \\ &#8211;zookeeper emr-header-1:2181,emr-header-2:2181,emr-header-3:2181\/kafka-1.0.1 \\ &#8211;topic T1 \\ &#8211;describe \u67e5\u770b\u6d88\u8d39\u8005\u7ec4 bin\/kafka-consumer-groups.sh \\ &#8211;bootstrap-server 172.1.2.3:9092,172.1.2.4:9092,172.1.2.5:9092 \\ &#8211;list \u67e5\u770b\u6d88\u8d39\u8005\u7ec4\u8be6\u60c5 bin\/kafka-consumer-groups.sh \\ &#8211;bootstrap-server 172.1.2.3:9092,172.1.2.4:9092,172.1.2.5:9092 \\ &#8211;group group_name1 \\ &#8211;describe \u67e5\u770b__consumer_offsets\u4e2d\u8bb0\u8f7d\u7684\u504f\u79fb\u91cf\u6570\u636e bin\/kafka-console-consumer.sh &#8211;topic __consumer_offsets \\ &#8211;bootstrap-server 172.1.2.3:9092,172.1.2.4:9092,172.1.2.5:9092 \\ &#8211;formatter &#8220;kafka.coordinator.group.GroupMetadataManager\\$OffsetsMessageFormatter&#8221; \\ &#8211;consumer.config config\/consumer.properties \\ &#8211;from-beginning | grep group_name1 \u67e5\u770btopic\u4fe1\u606f\u6700\u8fd15\u6761 bin\/kafka-console-consumer.sh \\ [&hellip;]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[7],"tags":[],"class_list":["post-505","post","type-post","status-publish","format-standard","hentry","category-java"],"_links":{"self":[{"href":"http:\/\/22pig.com\/index.php?rest_route=\/wp\/v2\/posts\/505","targetHints":{"allow":["GET"]}}],"collection":[{"href":"http:\/\/22pig.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/22pig.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/22pig.com\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"http:\/\/22pig.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=505"}],"version-history":[{"count":0,"href":"http:\/\/22pig.com\/index.php?rest_route=\/wp\/v2\/posts\/505\/revisions"}],"wp:attachment":[{"href":"http:\/\/22pig.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=505"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/22pig.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=505"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/22pig.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=505"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}