如果我没有指定分区数或者副本数,那么会如何创建?
我们都知道,如果我们没有指定分区数或者副本数, 则默认使用Broker的配置, 那么这么多Broker
假如不小心默认值配置不一样,那究竟使用哪一个呢？ 那肯定是哪台机器执行创建topic的过程,就是使用谁的配置;
所以是谁执行的？ 那肯定是Controller啊! 上面的源码我们分析到了,创建的过程,会指定Controller这台机器去进行;
《kafka问答100例 -3》 如果我没有指定分区数或者副本数,那么会如何创建
2021-12-29
131
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《
阿里云开发者社区用户服务协议》和
《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写
侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：
《kafka问答100例 -3》 如果我没有指定分区数或者副本数,那么会如何创建
目录
相关文章
|
4月前
|
消息中间件
分布式计算
算法
|
4月前
|
消息中间件
SQL
分布式计算
|
3月前
|
消息中间件
负载均衡
Kafka
【赵渝强老师】Kafka的主题与分区
Kafka 中的消息按主题分类，生产者发送消息到特定主题，消费者订阅主题消费。主题可分多个分区，每个分区仅属一个主题。消息追加到分区时，Broker 分配唯一偏移量地址，确保消息在分区内的顺序性。Kafka 保证分区有序而非主题有序。示例中，Topic A 有 3 个分区，分区可分布于不同 Broker 上，支持负载均衡和容错。视频讲解及图示详见原文。
94
2
2
|
3月前
|
消息中间件
监控
负载均衡
|
4月前
|
消息中间件
监控
负载均衡
|
3月前
|
消息中间件
Kafka
【赵渝强老师】Kafka分区的副本机制
在Kafka中，每个主题可有多个分区，每个分区有多个副本。其中仅有一个副本为Leader，负责对外服务，其余为Follower。当Leader所在Broker宕机时，Follower可被选为新的Leader，实现高可用。文中附有示意图及视频讲解。
142
0
0
|
4月前
|
消息中间件
JSON
大数据
大数据-65 Kafka 高级特性 分区 Broker自动再平衡 ISR 副本 宕机恢复再重平衡 实测
大数据-65 Kafka 高级特性 分区 Broker自动再平衡 ISR 副本 宕机恢复再重平衡 实测
126
4
4
|
4月前
|
消息中间件
分布式计算
算法
大数据-67 Kafka 高级特性 分区 分配策略 Ranger、RoundRobin、Sticky、自定义分区器
大数据-67 Kafka 高级特性 分区 分配策略 Ranger、RoundRobin、Sticky、自定义分区器
89
3
3
|
4月前
|
消息中间件
SQL
分布式计算
大数据-74 Kafka 高级特性 稳定性 - 控制器、可靠性 副本复制、失效副本、副本滞后 多图一篇详解
大数据-74 Kafka 高级特性 稳定性 - 控制器、可靠性 副本复制、失效副本、副本滞后 多图一篇详解
48
2
2
|
4月前
|
消息中间件
JSON
大数据
大数据-66 Kafka 高级特性 分区Partition 副本因子Replication Factor replicas动态修改 线上动态修改副本数
大数据-66 Kafka 高级特性 分区Partition 副本因子Replication Factor replicas动态修改 线上动态修改副本数
141
1
2
热门文章
最新文章
1
【赵渝强老师】Kafka生产者的执行过程
2
docker环境安装kafka/Flink/clickhouse镜像
3
docker compose 安装 kafka
4
【赵渝强老师】Kafka生产者的消息发送方式
5
【Azure Kafka】使用Spring Cloud Stream Binder Kafka 发送并接收 Event Hub 消息及解决并发报错
6
SQLServer CDC数据通过Kafka connect实时同步至分析型数据库 AnalyticDB For PostgreSQL及OSS
7
springboot配置kafka生产者和消费者详解
8
深入浅出理解kafka存储机制
9
kafka可视化工具
10
Kafka 3.0新特性 详解（二）
1
【赵渝强老师】Kafka生产者的消息发送方式
34
2
【赵渝强老师】Kafka生产者的执行过程
94
3
【Azure Kafka】使用Spring Cloud Stream Binder Kafka 发送并接收 Event Hub 消息及解决并发报错
24
4
docker环境安装kafka/Flink/clickhouse镜像
90
5
docker compose 安装 kafka
54
6
kafka 的数据是放在磁盘上还是内存上，为什么速度会快？
62
7
一文带你秒懂 Kafka工作原理！
945
8
云消息队列 Kafka 版 V3 系列荣获信通院“云原生技术创新标杆案例”
87
9
招行面试：RocketMQ、Kafka、RabbitMQ，如何选型？
165
10
【Azure Event Hub】Kafka消息发送失败(Timeout Exception)
130