{"id":9125,"date":"2020-10-10T10:53:42","date_gmt":"2020-10-10T02:53:42","guid":{"rendered":"https:\/\/jpuyy.com\/?p=9125"},"modified":"2020-10-10T10:53:42","modified_gmt":"2020-10-10T02:53:42","slug":"kafka-console-consumer-%e5%af%b9-topic-%e6%b5%8b%e8%af%95","status":"publish","type":"post","link":"https:\/\/jpuyy.com\/?p=9125","title":{"rendered":"kafka-console-consumer \u5bf9 topic \u6d4b\u8bd5"},"content":{"rendered":"<p>To listen for messages on a topic:                                              <\/p>\n<pre>                                                                                \r\nkafka-console-consumer --bootstrap-server kafka:9092 --topic test1 --from-beginning\r\n<\/pre>\n<p>To stop the listener session above press: Ctrl+C                                <\/p>\n<p>To start an interactive message producer session:                               <\/p>\n<pre>\r\nkafka-console-producer --broker-list kafka-headless:9092 --topic test1\r\n<\/pre>\n<p>To create a message in the above session, simply type the message and press &#8220;enter&#8221;<br \/>\nTo end the producer session try: Ctrl+C                                         <\/p>\n<p>If you specify &#8220;zookeeper.connect&#8221; in configurationOverrides, please replace &#8220;kafka-zookeeper:2181&#8221; with the value of &#8220;zookeeper.connect&#8221;, or you will get error.<\/p>\n","protected":false},"excerpt":{"rendered":"<p>To listen for messages on a topic: kafka-console-consumer &#8211;bootstrap-server kafka:9092 &#8211;topic test1 &#8211;from-beginning To stop the listener session above press: Ctrl+C To start an interactive message producer session: kafka-console-producer &#8211;broker-list kafka-headless:9092 &#8211;topic test1 To create a message in the above session, simply type the message and press &#8220;enter&#8221; To end the producer session try: Ctrl+C [&hellip;]<\/p>\n","protected":false},"author":3,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[183],"tags":[],"class_list":["post-9125","post","type-post","status-publish","format-standard","hentry","category-kafka"],"_links":{"self":[{"href":"https:\/\/jpuyy.com\/index.php?rest_route=\/wp\/v2\/posts\/9125","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/jpuyy.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/jpuyy.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/jpuyy.com\/index.php?rest_route=\/wp\/v2\/users\/3"}],"replies":[{"embeddable":true,"href":"https:\/\/jpuyy.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=9125"}],"version-history":[{"count":1,"href":"https:\/\/jpuyy.com\/index.php?rest_route=\/wp\/v2\/posts\/9125\/revisions"}],"predecessor-version":[{"id":9126,"href":"https:\/\/jpuyy.com\/index.php?rest_route=\/wp\/v2\/posts\/9125\/revisions\/9126"}],"wp:attachment":[{"href":"https:\/\/jpuyy.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=9125"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/jpuyy.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=9125"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/jpuyy.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=9125"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}