{"id":432,"date":"2018-09-10T22:34:28","date_gmt":"2018-09-10T13:34:28","guid":{"rendered":"http:\/\/dong1lkim.oboki.net\/?p=432"},"modified":"2019-09-01T22:21:04","modified_gmt":"2019-09-01T13:21:04","slug":"kafka-console-script-%ec%82%ac%ec%9a%a9%ed%95%98%ea%b8%b0","status":"publish","type":"post","link":"https:\/\/oboki.net\/workspace\/data-engineering\/kafka\/kafka-console-script-%ec%82%ac%ec%9a%a9%ed%95%98%ea%b8%b0\/","title":{"rendered":"[Kafka] Console Script \uc0ac\uc6a9\ud558\uae30"},"content":{"rendered":"<h1>Kafka Console Script \uc0ac\uc6a9\ud558\uae30<\/h1>\n<h2>kafka-topics.sh<\/h2>\n<h3>Create New Topic<\/h3>\n<blockquote><p>\n  &#8216;test&#8217; \ub77c\ub294 \uc774\ub984\uc758 topic \uc0dd\uc131\n<\/p><\/blockquote>\n<pre><code class=\"bash\">kafka-topics.sh \\\n--create --zookeeper node1.big:2181,node2.big:2181,node3.big:2181 \\\n--replication-factor 1 --partitions 1 \\\n--topic test\n<\/code><\/pre>\n<h3>Get List of Topics from Kafka Cluster<\/h3>\n<pre><code class=\"bash\">kafka-topics.sh \\\n--list --zookeeper node1.big:2181,node2.big:2181,node3.big:2181\n<\/code><\/pre>\n<h2>kafka-console-producer.sh<\/h2>\n<blockquote><p>\n  console-producer \uc774\uc6a9\ud558\uc5ec, bash \ud658\uacbd\uc5d0\uc11c \ud45c\uc900 \uc785\ub825\uc744 \ud1b5\ud574 &#8216;test&#8217;\ub77c\ub294 topic\uc5d0 message publish\n<\/p><\/blockquote>\n<pre><code class=\"bash\">kafka-console-producer.sh \\\n--broker-list node7.big:9092,node8.big:9092 --topic test\n<\/code><\/pre>\n<p>\uc704 \uba85\ub839 \uc218\ud589 \uc774\ud6c4 \ud130\ubbf8\ub110\uc5d0 \uc785\ub825\ud558\ub294 \uba54\uc2dc\uc9c0\ub97c publish \ud55c\ub2e4. newline \uc73c\ub85c record \uac00 \uad6c\ubd84 \ub428.<\/p>\n<h2>kafka-console-consumer.sh<\/h2>\n<blockquote><p>\n  console-consumer \uc774\uc6a9\ud558\uc5ec, &#8216;test&#8217;\ub77c\ub294 topic\uc758 message \uad6c\ub3c5\ud558\uae30\n<\/p><\/blockquote>\n<ul>\n<li>\ud574\ub2f9 topic\uc5d0 \ubcf4\uad00\ub3fc \uc788\ub294 \ubaa8\ub4e0 message \ud655\uc778\ud55c \ud6c4 \uc0c8\ub86d\uac8c publish \ub418\ub294 message \uad6c\ub3c5\n<pre><code class=\"bash\">kafka-console-consumer.sh \\\n--bootstrap-server node7.big:9092,node8.big:9092 --from-beginning \\\n--topic test\n<\/code><\/pre>\n<\/li>\n<li>\ud574\ub2f9 topic\uc5d0 \uc0c8\ub86d\uac8c publish \ub418\ub294 message \ubd80\ud130 \uad6c\ub3c5\n<pre><code class=\"bash\">kafka-console-consumer.sh \\\n--bootstrap-server node7.big:9092,node8.big:9092 \\\n--topic test\n<\/code><\/pre>\n<\/li>\n<\/ul>\n","protected":false},"excerpt":{"rendered":"<p>Kafka Console Script \uc0ac\uc6a9\ud558\uae30 kafka-topics.sh Create New Topic &#8216;test&#8217; \ub77c\ub294 \uc774\ub984\uc758 topic \uc0dd\uc131 kafka-topics.sh \\ &#8211;create &#8211;zookeeper node1.big:2181,node2.big:2181,node3.big:2181 \\ &#8211;replication-factor 1 &#8211;partitions 1 \\ &#8211;topic test Get List of Topics from Kafka Cluster kafka-topics.sh \\ &#8211;list &#8211;zookeeper node1.big:2181,node2.big:2181,node3.big:2181 kafka-console-producer.sh console-producer \uc774\uc6a9\ud558\uc5ec, bash \ud658\uacbd\uc5d0\uc11c \ud45c\uc900 \uc785\ub825\uc744 \ud1b5\ud574 &#8216;test&#8217;\ub77c\ub294 topic\uc5d0 message publish kafka-console-producer.sh \\ &#8211;broker-list node7.big:9092,node8.big:9092 &#8211;topic [&hellip;]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[16],"tags":[139],"class_list":["post-432","post","type-post","status-publish","format-standard","hentry","category-kafka","tag-kafka"],"_links":{"self":[{"href":"https:\/\/oboki.net\/workspace\/wp-json\/wp\/v2\/posts\/432","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/oboki.net\/workspace\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/oboki.net\/workspace\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/oboki.net\/workspace\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/oboki.net\/workspace\/wp-json\/wp\/v2\/comments?post=432"}],"version-history":[{"count":7,"href":"https:\/\/oboki.net\/workspace\/wp-json\/wp\/v2\/posts\/432\/revisions"}],"predecessor-version":[{"id":1233,"href":"https:\/\/oboki.net\/workspace\/wp-json\/wp\/v2\/posts\/432\/revisions\/1233"}],"wp:attachment":[{"href":"https:\/\/oboki.net\/workspace\/wp-json\/wp\/v2\/media?parent=432"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/oboki.net\/workspace\/wp-json\/wp\/v2\/categories?post=432"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/oboki.net\/workspace\/wp-json\/wp\/v2\/tags?post=432"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}