{"id":14643,"date":"2023-12-04T15:58:43","date_gmt":"2023-12-04T07:58:43","guid":{"rendered":"https:\/\/wx.kaifamiao.info\/?p=14643"},"modified":"2023-12-13T14:19:36","modified_gmt":"2023-12-13T06:19:36","slug":"kafka-zhong-ru-he-huo-qutopic-zhu-ti-de-lie-biao","status":"publish","type":"post","link":"http:\/\/wx.kaifamiao.info\/index.php\/2023\/12\/04\/kafka-zhong-ru-he-huo-qutopic-zhu-ti-de-lie-biao\/","title":{"rendered":"Kafka\u4e2d\u5982\u4f55\u83b7\u53d6topic\u4e3b\u9898\u7684\u5217\u8868\uff1f"},"content":{"rendered":"

\u5728 Kafka \u4e2d\uff0c\u53ef\u4ee5\u4f7f\u7528 Kafka \u7684\u547d\u4ee4\u884c\u5de5\u5177\u6216\u8005 Kafka \u7684\u5ba2\u6237\u7aef API \u6765\u83b7\u53d6\u4e3b\u9898\uff08topic\uff09\u7684\u5217\u8868\u3002\u4ee5\u4e0b\u662f\u4e24\u79cd\u5e38\u89c1\u7684\u65b9\u6cd5\uff1a<\/p>\n

<\/span><\/a>1. \u4f7f\u7528 Kafka \u547d\u4ee4\u884c\u5de5\u5177<\/h3>\n

\u4f7f\u7528 Kafka \u63d0\u4f9b\u7684\u547d\u4ee4\u884c\u5de5\u5177 kafka-topics.sh<\/code>\uff08Unix\/Linux\uff09\u6216 kafka-topics.bat<\/code>\uff08Windows\uff09\u53ef\u4ee5\u83b7\u53d6\u4e3b\u9898\u5217\u8868\u3002\u4ee5\u4e0b\u662f\u4e00\u4e2a\u83b7\u53d6\u4e3b\u9898\u5217\u8868\u7684\u793a\u4f8b\u547d\u4ee4\uff1a<\/p>\n

kafka-topics.sh --list --zookeeper <Zookeeper \u5730\u5740>\n<\/code><\/pre>\n
\u6216\u8005\u5728\u6700\u65b0\u7248\u672c\u7684 Kafka \u4e2d\uff0c\u53ef\u4ee5\u4f7f\u7528 --bootstrap-server<\/code> \u53c2\u6570\uff0c\u5982\u4e0b\uff1a<\/p>\n
kafka-topics.sh --list --bootstrap-server <Kafka Broker \u5730\u5740>\n<\/code><\/pre>\n
\u66ff\u6362 <Zookeeper \u5730\u5740><\/code> \u6216 <Kafka Broker \u5730\u5740><\/code> \u4e3a\u4f60\u5b9e\u9645\u7684 ZooKeeper \u5730\u5740\u6216 Kafka Broker \u5730\u5740\u3002<\/p>\n
<\/span><\/a>2. \u4f7f\u7528 Kafka \u5ba2\u6237\u7aef API<\/h3>\n
\u5728 Java \u7b49\u7f16\u7a0b\u8bed\u8a00\u4e2d\uff0c\u4e5f\u53ef\u4ee5\u4f7f\u7528 Kafka \u7684\u5ba2\u6237\u7aef API \u6765\u83b7\u53d6\u4e3b\u9898\u5217\u8868\u3002\u4ee5\u4e0b\u662f\u4e00\u4e2a\u7b80\u5355\u7684 Java \u793a\u4f8b\u4ee3\u7801\uff1a<\/p>\n
import org.apache.kafka.clients.admin.AdminClient;\nimport org.apache.kafka.clients.admin.ListTopicsOptions;\nimport org.apache.kafka.clients.admin.ListTopicsResult;\n\nimport java.util.Map;\nimport java.util.Set;\n\npublic class ListTopicsExample {\n    public static void main(String[] args) {\n        \/\/ \u8bbe\u7f6e Kafka \u96c6\u7fa4\u7684 Bootstrap \u670d\u52a1\u5668\u5730\u5740\n        String bootstrapServers = "localhost:9092";\n\n        \/\/ \u8bbe\u7f6e Kafka \u5ba2\u6237\u7aef\u5c5e\u6027\n        Map<String, Object> config = Map.of("bootstrap.servers", bootstrapServers);\n\n        \/\/ \u521b\u5efa AdminClient\n        try (AdminClient adminClient = AdminClient.create(config)) {\n            \/\/ \u8bbe\u7f6e ListTopicsOptions\n            ListTopicsOptions options = new ListTopicsOptions().listInternal(true);\n\n            \/\/ \u83b7\u53d6\u4e3b\u9898\u5217\u8868\n            ListTopicsResult topics = adminClient.listTopics(options);\n\n            \/\/ \u6253\u5370\u4e3b\u9898\u5217\u8868\n            Set<String> topicNames = topics.names().get();\n            for (String topic : topicNames) {\n                System.out.println("Topic: " + topic);\n            }\n        } catch (Exception e) {\n            e.printStackTrace();\n        }\n    }\n}\n<\/code><\/pre>\n
\u5728\u8fd9\u4e2a\u4f8b\u5b50\u4e2d\uff0c\u66ff\u6362 localhost:9092<\/code> \u4e3a\u4f60\u7684 Kafka \u96c6\u7fa4\u7684\u5b9e\u9645\u5730\u5740\u3002<\/p>\n
\u4ee5\u4e0a\u4e24\u79cd\u65b9\u6cd5\u90fd\u53ef\u4ee5\u7528\u4e8e\u83b7\u53d6 Kafka \u96c6\u7fa4\u4e2d\u6240\u6709\u4e3b\u9898\u7684\u5217\u8868\u4fe1\u606f\u3002\u547d\u4ee4\u884c\u5de5\u5177\u66f4\u9002\u7528\u4e8e\u5feb\u901f\u68c0\u67e5\u548c\u8c03\u8bd5\uff0c\u800c\u5ba2\u6237\u7aef API \u5219\u66f4\u9002\u7528\u4e8e\u96c6\u6210\u5230\u81ea\u5df1\u7684\u5e94\u7528\u7a0b\u5e8f\u4e2d\u8fdb\u884c\u7a0b\u5e8f\u5316\u64cd\u4f5c\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
\u5728 Kafka \u4e2d\uff0c\u53ef\u4ee5\u4f7f\u7528 Kafka \u7684\u547d\u4ee4\u884c\u5de5\u5177\u6216\u8005 Kafka \u7684\u5ba2\u6237\u7aef API \u6765\u83b7\u53d6\u4e3b\u9898\uff08topi […]<\/p>\n","protected":false},"author":9,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[122],"tags":[],"class_list":["post-14643","post","type-post","status-publish","format-standard","hentry","category-kafka"],"_links":{"self":[{"href":"http:\/\/wx.kaifamiao.info\/index.php\/wp-json\/wp\/v2\/posts\/14643","targetHints":{"allow":["GET"]}}],"collection":[{"href":"http:\/\/wx.kaifamiao.info\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/wx.kaifamiao.info\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/wx.kaifamiao.info\/index.php\/wp-json\/wp\/v2\/users\/9"}],"replies":[{"embeddable":true,"href":"http:\/\/wx.kaifamiao.info\/index.php\/wp-json\/wp\/v2\/comments?post=14643"}],"version-history":[{"count":2,"href":"http:\/\/wx.kaifamiao.info\/index.php\/wp-json\/wp\/v2\/posts\/14643\/revisions"}],"predecessor-version":[{"id":48014,"href":"http:\/\/wx.kaifamiao.info\/index.php\/wp-json\/wp\/v2\/posts\/14643\/revisions\/48014"}],"wp:attachment":[{"href":"http:\/\/wx.kaifamiao.info\/index.php\/wp-json\/wp\/v2\/media?parent=14643"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/wx.kaifamiao.info\/index.php\/wp-json\/wp\/v2\/categories?post=14643"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/wx.kaifamiao.info\/index.php\/wp-json\/wp\/v2\/tags?post=14643"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}