create_topic

2016-08-09 22:05:06   0  举报





仅支持查看

`create_topic` 是一个用于创建新主题的函数或方法。它通常用于在线论坛、博客或其他类似的平台上，允许用户创建一个新的讨论主题。这个函数或方法可能包括输入主题名称、描述和分类等参数，以便为新主题提供详细信息。在创建新主题后，其他用户可以查看、评论和参与讨论。`create_topic` 可以是一个独立的功能，也可以与其他功能（如搜索、排序和过滤）结合使用，以提供更好的用户体验。总之，`create_topic` 是一个方便用户发起新讨论的工具，有助于促进在线社区的交流和互动。

作者其他创作

大纲/内容

(4)

(6)

TopicCommand.createTopic

(2)

1. Partition状态机状态变化—— NonExistentPartition-NewPartition-OnlinePartition;2. Replica状态机变化—— NonExistentReplica-NewReplica-OnlineReplica;

(5)

TopicChangeListener.handleChildChange

监听到zk中/brokers/topics/子目录变化

1.获取哪些topic是新增的——从ZK中读取的新的topic列表减去ControllerContext中旧的的列表；2.在ControllerContext中更新AR列表——从ZK中读取新增topicAndPartition的AR信息，添加到ControllerContext相应map中；3.执行topic创建操作——调用onNewTopicCreation；

KafkaController.onNewPartitionCreation

1.当有新增partition时，zk路径/brokers/topics/[topic]/下内容变化；2.获取新增Partition列表——从ZK中获取新的partition和相应AR信息，与ControllerContext中旧的AR信息进行对比；3. 对新增的partition执行新建操作——onNewPartitionCreation;

KafkaController.onNewTopicCreation

在 /brokers/topics/[topic]/下写入AR信息，格式为：{\"partitionId1\":[\"replicaId1\

AddPartitionsListener.handleDataChange

1.订阅路径/brokers/topics/[topic]/下的内容变化——AddPartitionsListener类监听topic下的partition列表变化；2. 创建新的topic的所有分区—— onNewPartitionCreation;

(3)

(1)

监听zk下/brokers/topics/[topic]/目录下内容变化