kafka的常规操作命令

kafka的常规操作命令

kafka修改保留时间kafka-configs --zookeeper dbos-bigdata-tools001:2181,dbos-bigdata-tools002:2181,dbos-bigdata-tools003:2181 --entity-type topics --entity-name test_sony_boot_play --alter --add-config retention.ms=86400000查看topickafka-topics --zookeeper dbos-bigdata-tools001:2181,dbos-bigdata-tools002:2181,dbos-bigdata-tools003:2181 --describe --topic test_dbyy_init查看offsetskafka-topics --describe --zookeeper dbos-bigdata-tools001:2181,dbos-bigdata-tools002:2181,dbos-bigdata-tools003:2181 | grep consumer_offsets创建topickafka-topics --zookeeper dbos-bigdata-tools001:2181,dbos-bigdata-tools002:2181,dbos-bigdata-tools003:2181 --create --partitions 4 --replication-factor 1 --topic steven 新增加分区kafka-topics --zookeeper dbos-bigdata-test003:2181,dbos-bigdata-test004:2181,dbos-bigdata-test005:2181/kafka --alter --partitions 6 --topic steven新增副本kafka-reassign-partitions --zookeeper dbos-bigdata-test003:2181,dbos-bigdata-test004:2181,dbos-bigdata-test005:2181/kafka --reassignment-json-file increase-replication-factor.json --execute先创建以下json文件在执行{"version":1,"partitions":[{"topic":"steven","partition":0,"replicas":[172,173,174]},{"topic":"steven","partition":1,"replicas":[173,174,172]},{"topic":"steven","partition":2,"replicas":[174,172,173]},{"topic":"steven","partition":3,"replicas":[172,173,174]},{"topic":"steven","partition":4,"replicas":[173,174,172]},{"topic":"steven","partition":5,"replicas":[174,172,173]}]}

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。