• 香港特区总站,香港特区总站【首存红利200%】

  • 发布时间:2016-01-22 01:33 | 作者:yc | 来源:互联网 | 浏览:1200 次
  • 香港特区总站,香港特区总站【首存红利200%】

    1、添加kafka分区

    { "version":1,

    5、发动kafka

    }

    ./kafka-topics.sh --zookeeper 192.168.2.70 --list

    {"topic": "sync_database_update"},

    {"topic": "sync_vehicle_reg"},

    2)、实行分区规划

    9、删去topic

    {"topic": "us_forward"},

    {"topic": "us_packet"}

    {"topic": "sync_realtime_alarm"},

    {"topic": "us_ctrlrsp"},

    }

    1)、编写拓展文件,能够应用拓展集群的措施导出如今的漫衍然后做修正

    bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic page_visits --from-beginning

    /kafka-reassign-partitions.sh --zookeeper 192.168.2.70 --reassignment-json-file topics-to-move-execute.json --execute

    4、查看kafka各个组的偏移量

    5)、查看集群拓展是不是完结

    3)、把天生的主张分区保存成jsontopics-to-move-execute.json

    bin/kafka-console-producer.sh --broker-list localhost:9092 --topic page_visits

    bin/kafka-server-start.sh config/server.properties &

    /kafka-reassign-partitions.sh --zookeeper 192.168.2.70 --reassignment-json-f香港特区总站,香港特区总站【首存红利200%】台湾妹中文娱乐网3ile topics-to-move-execute.json --execute

    ./kafka-reassign-partitions.sh --zookeeper 192.168.2.70 --generate --topics-to-move-json-file topics-to-move.json--broker-list 1,2,3

    {"topic": "sync_station_info"},

    3)、查看集群拓展是不是完结

    ./kafka-topics.sh --zookeeper 192.168.2.70 --alter--topic us_forward--partitions 24

    8、花费音讯

    ],

    topic: us_general partition: 1 leader: 117 replicas: 117 isr: 117

    1)、先把要搬运的topic写成json格局topics-to-move.json

    11、拓展集群

    "partitions":[{"topic":"foo","partition":0,"replicas":[5,6,7]}]

    2)、用脚本天生一个主动分区的规划

    ./kafka-run-class.shkafka.tools.consumeroffsetchecker --zookeeper 192.168.110.165:2181 -group test_groupid

    7、发送音讯

    ./kafka-preferred-replica-election.sh --zookeeper 192.168.2.70

    这篇文章出自 “it事情者” 博客,请必须保存此出处http://luhaiyou.blog.51cto.com//

    12、添加副本数

    bin/kafka-topics.sh --zookeeper zk_host:port --delete --topic my_topic_name

    /kaf118kj.comka-reassign-partitions.sh --zookeeper 192.168.2.70 --reassignment-json-file topics-to-move-execute.json --verify

    ./kafka-topics.sh --zookeeper 192.168.2.70 --describe --topic us_general

    4)、实行分区规划

    topic: us_general partition: 0 leader: 117 replicas: 117 isr: 117

    {"topic": "us_general"},

    6、创立topic

    {"topics": [

    /kafka-reassign-partitions.sh --zookeeper 192.168.2.70 --reassignment-json-file topics-to-move-execute.json --verify

    2、查看kafka的topic

    3、查看单个topic的分区,也能够不加topic

    bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 24 --topic topic_test

    "version":1

    10、从头平衡分区和引导者

    {"topic": "ds_ctrlreq"},

  • 相关内容

友情链接: