{"id":46793,"date":"2023-11-02T01:52:42","date_gmt":"2023-09-20T14:17:02","guid":{"rendered":"https:\/\/www.silicloud.com\/zh\/blog\/kafka%e7%9a%84hello-world%e9%a1%b9%e7%9b%ae\/"},"modified":"2024-05-04T07:04:49","modified_gmt":"2024-05-03T23:04:49","slug":"kafka%e7%9a%84hello-world%e9%a1%b9%e7%9b%ae","status":"publish","type":"post","link":"https:\/\/www.silicloud.com\/zh\/blog\/kafka%e7%9a%84hello-world%e9%a1%b9%e7%9b%ae\/","title":{"rendered":"Kafka\u7684Hello World\u9879\u76ee"},"content":{"rendered":"<h1>\u5361\u592b\u5361\u73af\u5883<\/h1>\n<p>\u5361\u592b\u53611.1 \/ HDF 3.2<br \/>\nJDK 8<\/p>\n<h1>\u6587\u4ef6<\/h1>\n<div><img decoding=\"async\" class=\"post-images\" title=\"\" src=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7af7913a08637a697b99\/3-0.png\" alt=\"image.png\" \/><\/div>\n<pre class=\"post-pre\"><code>&lt;?xml version=\"1.0\" encoding=\"UTF-8\"?&gt;\r\n&lt;project xmlns=\"http:\/\/maven.apache.org\/POM\/4.0.0\"\r\n         xmlns:xsi=\"http:\/\/www.w3.org\/2001\/XMLSchema-instance\"\r\n         xsi:schemaLocation=\"http:\/\/maven.apache.org\/POM\/4.0.0 http:\/\/maven.apache.org\/xsd\/maven-4.0.0.xsd\"&gt;\r\n    &lt;modelVersion&gt;4.0.0&lt;\/modelVersion&gt;\r\n\r\n    &lt;groupId&gt;k.helloworld&lt;\/groupId&gt;\r\n    &lt;artifactId&gt;kafka&lt;\/artifactId&gt;\r\n    &lt;version&gt;1.0-SNAPSHOT&lt;\/version&gt;\r\n\r\n    &lt;dependencies&gt;\r\n        &lt;dependency&gt;\r\n            &lt;groupId&gt;org.apache.kafka&lt;\/groupId&gt;\r\n            &lt;artifactId&gt;kafka-clients&lt;\/artifactId&gt;\r\n            &lt;version&gt;1.1.0&lt;\/version&gt;\r\n        &lt;\/dependency&gt;\r\n        &lt;dependency&gt;\r\n            &lt;groupId&gt;org.slf4j&lt;\/groupId&gt;\r\n            &lt;artifactId&gt;slf4j-log4j12&lt;\/artifactId&gt;\r\n            &lt;version&gt;1.7.21&lt;\/version&gt;\r\n        &lt;\/dependency&gt;\r\n    &lt;\/dependencies&gt;\r\n&lt;\/project&gt;\r\n<\/code><\/pre>\n<pre class=\"post-pre\"><code><span class=\"c\"># Licensed to the Apache Software Foundation (ASF) under one or more\r\n# contributor license agreements.  See the NOTICE file distributed with\r\n# this work for additional information regarding copyright ownership.\r\n# The ASF licenses this file to You under the Apache License, Version 2.0\r\n# (the \"License\"); you may not use this file except in compliance with\r\n# the License.  You may obtain a copy of the License at\r\n#\r\n#    http:\/\/www.apache.org\/licenses\/LICENSE-2.0\r\n#\r\n# Unless required by applicable law or agreed to in writing, software\r\n# distributed under the License is distributed on an \"AS IS\" BASIS,\r\n# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r\n# See the License for the specific language governing permissions and\r\n# limitations under the License.\r\n<\/span><span class=\"py\">log4j.rootLogger<\/span><span class=\"p\">=<\/span><span class=\"s\">OFF, stdout<\/span>\r\n\r\n<span class=\"py\">log4j.appender.stdout<\/span><span class=\"p\">=<\/span><span class=\"s\">org.apache.log4j.ConsoleAppender<\/span>\r\n<span class=\"py\">log4j.appender.stdout.layout<\/span><span class=\"p\">=<\/span><span class=\"s\">org.apache.log4j.PatternLayout<\/span>\r\n<span class=\"py\">log4j.appender.stdout.layout.ConversionPattern<\/span><span class=\"p\">=<\/span><span class=\"s\">[%d] %p %m (%c:%L)%n<\/span>\r\n\r\n<span class=\"py\">log4j.logger.org.apache.kafka<\/span><span class=\"p\">=<\/span><span class=\"s\">ERROR<\/span>\r\n\r\n<\/code><\/pre>\n<pre class=\"post-pre\"><code>package com.zzeng;\r\n\r\nimport java.util.Properties;\r\nimport java.util.Scanner;\r\n\r\nimport org.apache.kafka.clients.producer.KafkaProducer;\r\nimport org.apache.kafka.clients.producer.Producer;\r\nimport org.apache.kafka.clients.producer.ProducerRecord;\r\nimport org.apache.kafka.clients.producer.RecordMetadata;\r\n\r\npublic class KafkaProducerExample {\r\n    private final static String TOPIC_NAME = \"topic_name\";\r\n\r\n    public static void main(String[] args) {\r\n        \/\/ produce a test message\r\n        \/\/ if u run this multiple times ... u will have multiple messages in the\r\n        \/\/ test_topic topic (as would be expected)\r\n        Producer&lt;String, String&gt; producer = KafkaProducerExample.createProducer();\r\n\r\n        Scanner sc = new Scanner(System.in);\r\n        try {\r\n            while (true) {\r\n                System.out.print(\"&gt; \");\r\n                String text = sc.nextLine();\r\n\r\n                ProducerRecord&lt;String, String&gt; recordToSend = new ProducerRecord&lt;String, String&gt;(TOPIC_NAME, \"message\",\r\n                        text + \" , timeInMillis=\" + System.currentTimeMillis());\r\n                try {\r\n                    \/\/ synchronous send.... get() waits for the computation to\r\n                    \/\/ finish\r\n                    RecordMetadata rmd = producer.send(recordToSend).get();\r\n                    System.out.printf(\"Message Sent ==&gt;&gt; topic = %s, partition = %s, offset = %d\\n\", rmd.topic(),\r\n                            rmd.partition(), rmd.offset());\r\n                } catch (Exception ex) {\r\n                    \/\/ this is test code...so don't judge me !!\r\n                    ex.printStackTrace();\r\n                }\r\n\r\n                if (text.equalsIgnoreCase(\"exit\")) {\r\n                    break;\r\n                }\r\n            }\r\n        } finally {\r\n            sc.close();\r\n        }\r\n    }\r\n\r\n    private static Producer&lt;String, String&gt; createProducer() {\r\n        Properties kafkaProps = new Properties();\r\n        kafkaProps.put(\"bootstrap.servers\", \"zzeng-hdp-1.field.hortonworks.com:6667\");\r\n        kafkaProps.put(\"key.serializer\", \"org.apache.kafka.common.serialization.StringSerializer\");\r\n        kafkaProps.put(\"value.serializer\", \"org.apache.kafka.common.serialization.StringSerializer\");\r\n        return new KafkaProducer&lt;String, String&gt;(kafkaProps);\r\n    }\r\n\r\n}\r\n\r\n<\/code><\/pre>\n<h1>\u6267\u884c<\/h1>\n<div><img decoding=\"async\" class=\"post-images\" title=\"\" src=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7af7913a08637a697b99\/8-0.png\" alt=\"image.png\" \/><\/div>\n<div><img decoding=\"async\" class=\"post-images\" title=\"\" src=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7af7913a08637a697b99\/9-0.png\" alt=\"image.png\" \/><\/div>\n","protected":false},"excerpt":{"rendered":"<p>\u5361\u592b\u5361\u73af\u5883 \u5361\u592b\u53611.1 \/ HDF 3.2 JDK 8 \u6587\u4ef6 &lt;?xml version=&#8221;1.0&#8243;  [&hellip;]<\/p>\n","protected":false},"author":3,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-46793","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"yoast_head":"<!-- This site is optimized with the Yoast SEO Premium plugin v21.5 (Yoast SEO v21.5) - https:\/\/yoast.com\/wordpress\/plugins\/seo\/ -->\n<title>Kafka\u7684Hello World\u9879\u76ee - Blog - Silicon Cloud<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.silicloud.com\/zh\/blog\/kafka\u7684hello-world\u9879\u76ee\/\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"Kafka\u7684Hello World\u9879\u76ee\" \/>\n<meta property=\"og:description\" content=\"\u5361\u592b\u5361\u73af\u5883 \u5361\u592b\u53611.1 \/ HDF 3.2 JDK 8 \u6587\u4ef6 &lt;?xml version=&quot;1.0&quot; [&hellip;]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.silicloud.com\/zh\/blog\/kafka\u7684hello-world\u9879\u76ee\/\" \/>\n<meta property=\"og:site_name\" content=\"Blog - Silicon Cloud\" \/>\n<meta property=\"article:published_time\" content=\"2023-09-20T14:17:02+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2024-05-03T23:04:49+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7af7913a08637a697b99\/3-0.png\" \/>\n<meta name=\"author\" content=\"\u97f5, \u79d1\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"\u97f5, \u79d1\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"3 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/kafka%e7%9a%84hello-world%e9%a1%b9%e7%9b%ae\/\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/kafka%e7%9a%84hello-world%e9%a1%b9%e7%9b%ae\/\",\"name\":\"Kafka\u7684Hello World\u9879\u76ee - Blog - Silicon Cloud\",\"isPartOf\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\"},\"datePublished\":\"2023-09-20T14:17:02+00:00\",\"dateModified\":\"2024-05-03T23:04:49+00:00\",\"author\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/kafka%e7%9a%84hello-world%e9%a1%b9%e7%9b%ae\/#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.silicloud.com\/zh\/blog\/kafka%e7%9a%84hello-world%e9%a1%b9%e7%9b%ae\/\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/kafka%e7%9a%84hello-world%e9%a1%b9%e7%9b%ae\/#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.silicloud.com\/zh\/blog\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"Kafka\u7684Hello World\u9879\u76ee\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/\",\"name\":\"Blog - Silicon Cloud\",\"description\":\"\",\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e\",\"name\":\"\u97f5, \u79d1\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g\",\"caption\":\"\u97f5, \u79d1\"},\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/author\/yunke\/\"},{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/kafka%e7%9a%84hello-world%e9%a1%b9%e7%9b%ae\/#local-main-organization-logo\",\"url\":\"\",\"contentUrl\":\"\",\"caption\":\"Blog - Silicon Cloud\"}]}<\/script>\n<!-- \/ Yoast SEO Premium plugin. -->","yoast_head_json":{"title":"Kafka\u7684Hello World\u9879\u76ee - Blog - Silicon Cloud","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.silicloud.com\/zh\/blog\/kafka\u7684hello-world\u9879\u76ee\/","og_locale":"zh_CN","og_type":"article","og_title":"Kafka\u7684Hello World\u9879\u76ee","og_description":"\u5361\u592b\u5361\u73af\u5883 \u5361\u592b\u53611.1 \/ HDF 3.2 JDK 8 \u6587\u4ef6 &lt;?xml version=\"1.0\" [&hellip;]","og_url":"https:\/\/www.silicloud.com\/zh\/blog\/kafka\u7684hello-world\u9879\u76ee\/","og_site_name":"Blog - Silicon Cloud","article_published_time":"2023-09-20T14:17:02+00:00","article_modified_time":"2024-05-03T23:04:49+00:00","og_image":[{"url":"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d7af7913a08637a697b99\/3-0.png"}],"author":"\u97f5, \u79d1","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"\u97f5, \u79d1","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"3 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.silicloud.com\/zh\/blog\/kafka%e7%9a%84hello-world%e9%a1%b9%e7%9b%ae\/","url":"https:\/\/www.silicloud.com\/zh\/blog\/kafka%e7%9a%84hello-world%e9%a1%b9%e7%9b%ae\/","name":"Kafka\u7684Hello World\u9879\u76ee - Blog - Silicon Cloud","isPartOf":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website"},"datePublished":"2023-09-20T14:17:02+00:00","dateModified":"2024-05-03T23:04:49+00:00","author":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e"},"breadcrumb":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/kafka%e7%9a%84hello-world%e9%a1%b9%e7%9b%ae\/#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.silicloud.com\/zh\/blog\/kafka%e7%9a%84hello-world%e9%a1%b9%e7%9b%ae\/"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.silicloud.com\/zh\/blog\/kafka%e7%9a%84hello-world%e9%a1%b9%e7%9b%ae\/#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.silicloud.com\/zh\/blog\/"},{"@type":"ListItem","position":2,"name":"Kafka\u7684Hello World\u9879\u76ee"}]},{"@type":"WebSite","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website","url":"https:\/\/www.silicloud.com\/zh\/blog\/","name":"Blog - Silicon Cloud","description":"","inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/6530331a63adef3b3443a1fab53a0e6e","name":"\u97f5, \u79d1","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/429ccb39b3fff5188bc17986222cfb0936cbadb8cc933cff04ab5ca01bd30a08?s=96&d=mm&r=g","caption":"\u97f5, \u79d1"},"url":"https:\/\/www.silicloud.com\/zh\/blog\/author\/yunke\/"},{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/kafka%e7%9a%84hello-world%e9%a1%b9%e7%9b%ae\/#local-main-organization-logo","url":"","contentUrl":"","caption":"Blog - Silicon Cloud"}]}},"_links":{"self":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46793","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/users\/3"}],"replies":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/comments?post=46793"}],"version-history":[{"count":2,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46793\/revisions"}],"predecessor-version":[{"id":96846,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/46793\/revisions\/96846"}],"wp:attachment":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/media?parent=46793"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/categories?post=46793"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/tags?post=46793"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}