创建一个带副本机制的topic
** 通过下面的命令去创建带2个副本的topic
sh kafka-topics.sh --create --zookeeper 192.168.11.156:2181 --replication-factor
3 --partitions 3 --topic secondTopic
然后我们可以在/tmp/kafka-log路径下看到对应topic的副本信息了。我们通过一个图形的方式来表达。
针对secondTopic这个topic的3个分区对应的3个副本
如何知道那个各个分区中对应的leader是谁呢?
在zookeeper服务器上,通过如下命令去获取对应分区的信息, 比如下面这个是获取secondTopic第1个分区的状态信息。
get /brokers/topics/secondTopic/partitions/1/state
{"controller_epoch":12,"leader":0,"version":1,"leader_epoch":0,"isr":[0,1]}
或通过这个命令sh kafka-topics.sh --zookeeper 192.168.13.106:2181 --describe --topic
test_partition
leader表示当前分区的leader是那个broker-id。下图中。绿色线条的表示该分区中的leader节点。其他节点就为follower
需要注意的是,kafka集群中的一个broker中最多只能有一个副本,leader副本所在的broker节点的分区叫leader节点,follower副本所在的broker节点的分区叫follower节点
创建一个带副本机制的topic相关推荐
- python怎么创建列表_用Python将一个列表分割成小列表的实例讲解 Python 如何创建一个带小数的列表...
python里有一个列表,列表里有几个小列表,小列表#冒泡排序:scoreList = [['a',98],['c',45],['b',70],['d',85],['h',85],['f',92],[ ...
- 微信服务号如何创建一个带参数的微信二维码?
渠道二维码,也称为渠道码,带参二维码,带参统计二维码,顾名思义,渠道二维码的意思就是通过创建一个带参数的二维码来自动统计各渠道数据,是微信公众平台为服务号提供的一种开放接口功能,适用于多种扫码场景,例 ...
- 【区块链实战】如何创建一个带参数的智能合约
目录 一.简介 二.知识点 智能合约 Solidity 公共变量 Solidity 私有变量 以太坊椭圆曲线算法 keccak256 abi 转码 智能合约编译,部署和运行 三.菜鸟实战 四.运行结果 ...
- 「六」创建一个带 weblogic 服务的基础镜像
Weblogic Weblogic 简单介绍以及其在 Docker 环境下的特殊应用 WebLogic是美国Oracle公司出品的一个application server确切的说是一个基于JAVAEE ...
- 创建一个带参数的formgoup_基于原生Fabric-SDK-Go 实现一个简单的学历征信系统,状态数据库使用 CouchDB 来实现...
[TOC] 1. 需求分析与架构设计 我们要基于 原生Fabric-SDK-Go 实现一个简单的学历征信系统(web项目),状态数据库使用 CouchDB 来实现. 1.1 需求分析 现在是一个信息化 ...
- 如何创建一个带诊断工具的.NET镜像
现阶段的问题 现在是云原生和容器化时代,.NET Core对于云原生来说有非常好的兼容和亲和性,dotnet社区以及微软为.NET Core提供了非常方便的镜像容器化方案.所以现在大多数的dotnet ...
- Unreal Engin_Maya插件ArtV1_001初认Artv1创建一个带绑定的人物对其进行简单的设置
ArtV1 该插件是应用与虚幻引擎中对动画动作的快捷插件,在我现在的认知范围内是一个可以直接到处到虚幻中动作的一个很方便的插件. 如何下载: 首先可以在虚幻商城中收缩ARTV1 ...
- 「五」创建一个带 tomcat 服务的基础镜像(修订版)
Tomcat Tomcat 简单介绍 Tomcat server是一个免费的开放源码的Web 应用server,属于轻量级应用server.在中小型系统和并发訪问用户不是非常多的场合下被普遍使用,是开 ...
- 创建一个带参数的formgoup_gin框架如何获取带文件的formData请求?
**前端代码如下** ``` function upFile() { var formData = new FormData var file = document.getElementById(&q ...
最新文章
- python任意输入一个正整数、判断该数是否为素数_Python编程判断一个正整数是否为素数的方法,python素数...
- tar -cvPf new.tar `rpm -ql vsftpd` 建议不要用绝对路径'/'
- 使用JSONP,jQuery的ajax跨域获取json数据
- UDP 通讯协议 局域网通信发送消息 简单实现
- kafka实现组内广播
- 华为荣耀手机指令代码大全_2020.10月《各价位华为、荣耀手机推荐》
- JavaCore HeapDump
- java简单的小程序_编写一个简单的入门java小程序
- MySql触发器讲解及使用案例
- 图像的上采样、下采样
- 小米笔记本pro充电测试软件,一款给人心理落差较大的笔记本--小米笔记本Pro测评...
- 主分区损坏diskgenius_Diskgenius硬盘分区表坏了不要紧 用软件三步就能修复
- android 没有menu菜单键,android之onCreateOptionsMenu失效,按菜单键无反应
- 权威大数据应用解决方案
- Markdown 内如何使用表情符号
- 微信小程序之二级联动下拉列表
- Altium Designer -- EMC/EMI电路设计经验
- 影院卖品既然除了爆米花都卖不动,为什么不降价?
- 巨头争相布局的AI医疗,随着热潮褪去AI赛道会变宽松点吗?
- scratch编程 蓝桥杯编程题 红绿灯