1.概述

首先参考文章：【kafka】kafka 0.10以及1.x版本的kafka topic 分区扩容

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

然后写了一个方法如下

/*** 添加主分区* @param zkUrl* @param topicName* @param partition* @param replcation* @return*/public static boolean addPartition

【kafka】kafka 2.3 版本的kafka topic 分区扩容相关推荐

【kafka】kafka 0.10以及1.x版本的kafka topic 分区扩容
文章目录 1.概述 1.1 replicaAssignmentStr为空 1.2 指定副本 1.概述因为需要所以需要一个程序对kafka进行扩容处理然后写了一个方法如下 /**** @param ...
【Kafka】Kafka 0.10.0版本获取Kafka每个分区最新Offset的几种方法
1.概述脚本方法 [root@1 kafka]# ./bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list xxx:9092
解开Kafka神秘的面纱(二)：Kafka的高效读写与消息安全
文章目录一.前言二.Kafka消息队列 2.1 生产者生产kafka中的消息数据 2.1.1 生产者生产kafka中的消息数据 2.1.2 kafka生产者高效写盘 2.2 消费者消费kafka中 ...
Kafka 监控 Kafka Eagle 图形化版本
文章目录一.Kafka Eagle 下载.编译流程 1. Kafka Eagle下载 2. 解压Kafka Eagle 3. 进入解压的目录 4. 编译项目 5. 添加编译环境 6. 运行脚本编译项 ...
kafka版本_Apache Kafka 版本演进及特性介绍
前段时间有一个同事问到:Kafka 0.8.2 只能使用Zookeeper连接吗?虽然仍有一部分Kafka的老用户在使用 0.8.x 版本,但 Kafka 0.8.x 确实是比较老的版本了.如果不是对 ...
Kafka原理——fabric1.0版本中的节点排序方法
Kafka原理可参考Zookeeper一起理解,后续自己在项目中实现,会再来补充一些实践的内容. Zookeeper整理:https://blog.csdn.net/yangwei256/artic ...
kafka 修改分区_Kafka动态调整topic分区partition - russle的专栏 - CSDN博客
我们在使用kafka时,初期创建时所指定topic属性需要修改,如何动态修改kafka属性?kafka提供了命令行工具-kafka-topics.sh. kafka-topics.sh工具介绍 kaf ...
kafka文档（2）----kafka API（java版本）
原文地址: http://kafka.apache.org/documentation.html#api 当前正在重写kafka的JVM客户端.kafka 0.8.2包含的java produce ...
Flink从Kafka 0.8中读取多个Topic时的问题
Flink提供了FlinkKafkaConsumer08,使用Kafka的High-level接口,从Kafka中读取指定Topic的数据,如果要从多个Topic读取数据,可以如下操作: 1.appl ...

【kafka】kafka 2.3 版本的kafka topic 分区扩容

文章目录

1.概述

【kafka】kafka 2.3 版本的kafka topic 分区扩容相关推荐

最新文章

热门文章