kafkakafka 0.10以及1.x版本的kafka topic 分区扩容

Posted 九师兄

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了kafkakafka 0.10以及1.x版本的kafka topic 分区扩容相关的知识,希望对你有一定的参考价值。


1.概述

因为需要所以需要一个程序对kafka进行扩容处理

然后写了一个方法如下

/**
     *
     * @param zkUrl
     * @param topicName
     * @param partition
     * @param replicaAssignmentStr
     *      副本分配方案为格式 "2:1,3:1" 这里表示的是2个分区分别对应的副本情况,0分区对应的brokerid为
     *      2 和 1 的,1分区对应的副本为 3,1 不同的分区的副本用逗号分隔,同一个分区的多个副本之间用冒号
     *      分隔,同时需要注意的是,副本分配方案要报考已有分区的副本分配信息根据分配顺序从左到右依次与分区对应
     *     

以上是关于kafkakafka 0.10以及1.x版本的kafka topic 分区扩容的主要内容,如果未能解决你的问题,请参考以下文章

kafkakafka duplicate brokers in replica assignment

kafka之consumer参数auto.offset.reset 0.10+

KafkaKafka版本的 watermark 迟来的消息 直接报错

kafkaKafka源码解析 - LogSegment以及Log初始化

kafkakafka 查看 GroupCoordinator 以及 kafka Group dead 消费组死掉 以及 GroupCoordinatorRequest 使用

Kafka全面进入2.x时代