{"id":1157,"date":"2018-12-12T06:31:24","date_gmt":"2018-12-12T06:31:24","guid":{"rendered":"https:\/\/www.ipcpu.com\/?p=1157"},"modified":"2019-02-27T06:33:20","modified_gmt":"2019-02-27T06:33:20","slug":"kafka-command","status":"publish","type":"post","link":"https:\/\/c.ipcpu.com\/2018\/12\/kafka-command\/","title":{"rendered":"Kafka\u5e38\u7528\u547d\u4ee4"},"content":{"rendered":"

Kafka\u5e38\u7528\u547d\u4ee4.md<\/p>\n

Topic\u76f8\u5173<\/h2>\n
\n
##\u67e5\u770b\u6240\u6709topic\r\n.\/kafka-topics.sh --zookeeper localhost:2181 --list\r\n##\u67e5\u770btopic\u8be6\u60c5(\u5206\u533a\u548c\u526f\u672c)\r\n.\/kafka-topics.sh --zookeeper localhost:2181 --describe --topic topic.dau\r\n##\u67e5\u770bUnderReplicated\u5931\u6548\u5206\u533a\r\n.\/kafka-topics.sh --zookeeper localhost:2181 --describe --under-replicated-partitions<\/code><\/pre>\n<\/div>\n
\u6d88\u8d39\u8005\u76f8\u5173<\/h2>\n
\n
##\u67e5\u770b\u6240\u6709\u6d88\u8d39\u8005\u5217\u8868\r\n.\/kafka-consumer-groups.sh --bootstrap-server 172.28.9.65:9092 --list\r\n(\u53ea\u80fd\u663e\u793anon-ZooKeeper-based consumers)\r\n.\/kafka-consumer-groups.sh --zookeeper localhost:2181 --list\r\n(\u53ea\u80fd\u663e\u793aZooKeeper\u6d88\u8d39\u8005)\r\n##\u67e5\u770b\u6d88\u8d39\u8005\u8be6\u7ec6\u4fe1\u606f(\u5305\u542bIP\u5730\u5740\u548c\u7aef\u53e3\u4fe1\u606f)\r\n.\/kafka-consumer-groups.sh --bootstrap-server 172.28.0.65:9092 --describe --group group_new_device\r\n.\/kafka-consumer-groups.sh --zookeeper 127.0.0.1:2181 --describe --group ip_save<\/code><\/pre>\n<\/div>\n
\u589e\u52a0topic\u5206\u533a\u6570<\/h2>\n
\n
.\/kafka-topics.sh --zookeeper localhost:2181 --topic nginxaccess --alter --partitions 3<\/code><\/pre>\n<\/div>\n
\u8fd9\u91cc\u6709\u4e00\u70b9\u9700\u8981\u683c\u5916\u6ce8\u610f\uff0ckafka\u4e0d\u652f\u6301\u51cf\u5c11\u5206\u533a\u6570\uff0c\u53ef\u80fd\u662f\u5b9e\u73b0\u4e0a\u6bd4\u8f83\u590d\u6742\u5427\uff0c\u9700\u8981\u8003\u8651\u51cf\u5c11\u7684\u5206\u533a\u6570\u636e\u95ee\u9898\u3002\u800c\u526f\u672c\u6570\u53ef\u4ee5\u589e\u52a0\u4e5f\u53ef\u4ee5\u51cf\u5c11\u3002 
\n\u53e6\u5916\uff0c\u589e\u52a0\u4e86\u5206\u533a\u4ee5\u540e\uff0c\u751f\u4ea7\u8005\u53ef\u80fd\u9700\u8981\u91cd\u542f\u4e00\u4e0b\uff0c\u5426\u5219\u5728\u77ed\u65f6\u95f4\u5185\u65b0\u589e\u7684\u5206\u533a\u6ca1\u6709\u6570\u636e\u3002<\/p>\n
\u589e\u52a0\u6216\u8005\u51cf\u5c11topic\u5206\u533a\u7684\u526f\u672c<\/h2>\n
\u5148\u67e5\u8be2\u73b0\u6709topic\u7684partitions\u548c\u73b0\u6709\u526f\u672c\u7684\u5206\u5e03\u60c5\u51b5<\/p>\n
\n
 .\/kafka-topics.sh --zookeeper localhost:2181 --describe --topic nginxaccess<\/code><\/pre>\n<\/div>\n
\u7136\u540e\u7f16\u5199json\u6587\u4ef6<\/p>\n
\n
cat > increase-replication-factor.json <<EOF\r\n{\"version\":1, \"partitions\":[\r\n{\"topic\":\"topicpc\",\"partition\":0,\"replicas\":[0,1]},\r\n{\"topic\":\"topicpc\",\"partition\":1,\"replicas\":[1,2]},\r\n{\"topic\":\"topicpc\",\"partition\":2,\"replicas\":[0,2]}]\r\n}\r\nEOF<\/code><\/pre>\n<\/div>\n
\u7136\u540e\u6267\u884c\u91cd\u5206\u914d<\/p>\n
\n
.\/kafka-reassign-partitions.sh --zookeeper localhost:2181 --reassignment-json-file increase-replication-factor.json --execute<\/code><\/pre>\n<\/div>\n
\u9ed8\u8ba4\u5206\u533a\u548c\u526f\u672c\u6570<\/h2>\n
server.properties<\/p>\n
\n
num.partitions=3\r\ndefault.replication.factor=2<\/code><\/pre>\n<\/div>\n
\u53c2\u8003\u8d44\u6599<\/h2>\n
http:\/\/orchome.com\/454<\/a><\/p>\n
<\/p>\n
<\/div>\n
<\/div>\n
\n
<\/div>\n
<\/div>\n
<\/div>\n
<\/div>\n
<\/div>\n<\/div>\n
\n
<\/div>\n
<\/div>\n
<\/div>\n
<\/div>\n
<\/div>\n<\/div>\n
<\/wiz_tmp_tag><\/p>\n
\u8f6c\u8f7d\u8bf7\u6ce8\u660e\uff1aIPCPU-\u7f51\u7edc\u4e4b\u8def<\/a> » Kafka\u5e38\u7528\u547d\u4ee4<\/a><\/p>","protected":false},"excerpt":{"rendered":"
Kafka\u5e38\u7528\u547d\u4ee4.md Topic\u76f8\u5173 ##\u67e5\u770b\u6240\u6709topic .\/kafka-topics.sh –zookeeper localhost:2181 –list ##\u67e5\u770btopic\u8be6\u60c5(\u5206\u533a\u548c\u526f\u672c) .\/kafka-topics.sh –zookeeper localhost:2181 –describe –topic topic.dau ##\u67e5\u770bUnderReplicated\u5931\u6548\u5206\u533a .\/kafka-topics.sh –zookeeper localhost:2181 –describe –under-replicated-partitions \u6d88\u8d39\u8005\u76f8\u5173 ##\u67e5\u770b\u6240\u6709\u6d88\u8d39\u8005\u5217\u8868 .\/kafka-consumer-groups.sh –bootstrap-server 172.28.9.65:9092 –list (\u53ea\u80fd\u663e\u793anon-ZooKeeper-based consumers) .\/kafka-consumer-groups.sh –zookeeper localhost:2181 –list (\u53ea\u80fd\u663e\u793aZooKeeper\u6d88\u8d39\u8005) ##\u67e5\u770b\u6d88\u8d39\u8005\u8be6\u7ec6\u4fe1\u606f(\u5305\u542bIP\u5730\u5740\u548c\u7aef\u53e3\u4fe1\u606f) .\/kafka-consumer-groups.sh –bootstrap-server 172.28.0.65:9092 –describe –group group_new_device .\/kafka-consumer-groups.sh –zookeeper 127.0.0.1:2181 –describe –group ip_save \u589e\u52a0topic\u5206\u533a\u6570 .\/kafka-topics.sh –zookeeper localhost:2181 –topic nginxaccess –alter –partitions 3 […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":[],"categories":[13],"tags":[140,17,187],"_links":{"self":[{"href":"https:\/\/c.ipcpu.com\/wp-json\/wp\/v2\/posts\/1157"}],"collection":[{"href":"https:\/\/c.ipcpu.com\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/c.ipcpu.com\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/c.ipcpu.com\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/c.ipcpu.com\/wp-json\/wp\/v2\/comments?post=1157"}],"version-history":[{"count":2,"href":"https:\/\/c.ipcpu.com\/wp-json\/wp\/v2\/posts\/1157\/revisions"}],"predecessor-version":[{"id":1160,"href":"https:\/\/c.ipcpu.com\/wp-json\/wp\/v2\/posts\/1157\/revisions\/1160"}],"wp:attachment":[{"href":"https:\/\/c.ipcpu.com\/wp-json\/wp\/v2\/media?parent=1157"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/c.ipcpu.com\/wp-json\/wp\/v2\/categories?post=1157"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/c.ipcpu.com\/wp-json\/wp\/v2\/tags?post=1157"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}