标签：操作命令 -- bigdata 常规 kafka topic 2181 steven dbos

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

查看topic
kafka-topics --zookeeper dbos-bigdata-tools001:2181,dbos-bigdata-tools002:2181,dbos-bigdata-tools003:2181 --describe --topic test_dbyy_init

查看offsets
kafka-topics --describe --zookeeper dbos-bigdata-tools001:2181,dbos-bigdata-tools002:2181,dbos-bigdata-tools003:2181 | grep consumer_offsets

创建topic
kafka-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]}

]

}

了解更多大数据培训课程相关技术知识欢迎关注小编！ 

标签：操作命令,--,bigdata,常规,kafka,topic,2181,steven,dbos
来源： https://www.cnblogs.com/majhw/p/15503006.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。