Advertisement

kafka第二篇——主题创建, 主题分区副本分配策略

阅读量:

目录

主题创建

引入

回顾主题,分区,副本关系

代码

主题分区副本分配策略

底层逻辑分析


主题创建

引入

为什么刚一开始在IDEA上执行代码时(topic未被创建),系统却直接运行起来了?
由于AutoTopicCreationManger参数被配置为默认开启主题自动生成功能(通常并非我们所需),因此会出现此情况。

在Kafka客户端库中定义了一个名为Admin的类,在此基础之上为集群管理提供了相应的交互功能。该类为集群管理提供了相应的交互功能,并允许用户通过调用该对象的相应方法或属性(如创建主题、删除主题等),即可完成这些操作。

topic的三个参数

![](https

全部评论 (0)

还没有任何评论哟~