Kafka 常用命令汇总
原创Kafka 常用命令汇总
原创
owenyuan
修改于 2018-07-09 11:40:17
修改于 2018-07-09 11:40:17
修改topic 配置参数 —— 改保持时间
./kafka-topics.sh --zookeeper 1.1.1.1:2181/kafka --alter --topic Barad_Comm --config retention.ms=43200000修改topic 配置参数 —— max.message.bytes
./kafka-topics.sh --zookeeper 1.1.1.1:2181/kafka --alter --topic Barad_Comm --config max.message.bytes=5242880创建topic
./kafka-topics.sh --zookeeper 1.1.1.1:2181/kafka --create --topic Barad_Comm --partitions 16 --replication-factor 2查看topic
./kafka-topics.sh --zookeeper 1.1.1.1:2181/kafka --describe --topic Barad_Commkafka leader 调整
kafka 自带调整工具kafka-preferred-replica-election.sh
编辑需要调整的topic 及partition ,保存为json文件。内容如下：
{
"partitions":
[
{"topic":"Barad_Comm","partition": 4 },
{"topic":"Barad_Comm","partition": 5},
{"topic":"Barad_Comm","partition": 6},
{"topic":"Barad_Comm","partition": 7}
]
}执行如下命令：
bin/kafka-preferred-replica-election.sh --zookeeper 1.1.1.1:2181/kafka --path-to-json-file topicPartitionList.json【备注】注意修改替换zookeeper 参数，以上命令适合于0.8.1 ，其余版本未做验证
最后通过describe 命令查看调整结果。
原创声明：本文系作者授权腾讯云开发者社区发表，未经许可，不得转载。
如有侵权，请联系 cloudcommunity@tencent.com 删除。
原创声明：本文系作者授权腾讯云开发者社区发表，未经许可，不得转载。
如有侵权，请联系 cloudcommunity@tencent.com 删除。
评论
登录后参与评论
推荐阅读
目录