kafka创建Topic的一道面试题

当你使用kafka-topics.sh创建（删除）了一个topic之后，Kafka背后会执行什么逻辑？
1）会在zookeeper中的/brokers/topics节点下创建一个新的topic节点，如：/brokers/topics/first

2）触发Controller的监听程序

3）kafka Controller 负责topic的创建工作，并更新metadata cache

对以上内容进行验证,首先启动zookeeper,查看

[zk: localhost:2181(CONNECTED) 3] ls /kafka/brokers/topics
[mingxing, test-ex1, test, pet, __consumer_offsets, __transaction_state]

接下来新建一个topic

kafka-topics.sh \
--zookeeper mypc01:2181,mypc02:2181,mypc03:2181/kafka \
--create \
--topic csdn \
--partitions 3 \
--replication-factor 3

再次查看,多了一个topic csdn. 就是说在zk的brokers节点下的topics节点下维护了这个信息.

[zk: localhost:2181(CONNECTED) 4] ls /kafka/brokers/topics
[test-ex1, test, csdn, __transaction_state, mingxing, pet, __consumer_offsets]

kafka创建Topic的一道面试题相关推荐

kafka创建topic报错
kafka创建topic报错 kafka-topics.sh \ --zookeeper mypc01:2181,mypc02:2181,mypc03:2181/kafka-2020 \ --crea ...
Kafka创建Topic出现replication factor: 2 larger than available brokers: 0 减少replication factor还是出现错误的解决办法
Kafka创建Topic出现replication factor: 2 larger than available brokers: 0 减少replication factor还是出现错误的解决办法 ...
Kafka创建Topic的两种方式
创建topic的两种方式: 方法一: bin/kafka-topics.sh --create --topic topicname --replication-factor 1 --partition ...
Kafka创建topic
1 背景安装成功了kafka,需要创建topic 2 步骤进入到bin目录 ,必须要有kafka-topics.sh ./kafka-topics.sh --zookeeper localhost ...
kafka创建Topic出现的问题
replication factor: 3 larger than available brokers: 1 [2018-12-15 07:25:43,621] ERROR org.apache.ka ...
Kafka创建Topic时如何将分区放置到不同的Broker中
熟悉 Kafka 的同学肯定知道,每个主题有多个分区,每个分区会存在多个副本,本文今天要讨论的是这些副本是怎么样放置在 Kafka 集群的 Broker 中的. 大家可能在网上看过这方面的知识,网上对 ...
kafka创建topic命令_0748-5.14.4-Kafka的扩容和缩容
文档编写目的在Kafka集群资源使用已超出系统配置的资源时,或者有大量资源闲置造成资源浪费的时候,需要分别通过扩容Kafka和缩容Kafka来进行调整.本篇文章Fayson主要介绍如何进行Kafk ...
【kafka】kafka创建topic如何确定分区，如何计算kafka机器台数
1.创建test topic 单分区 bin/kafka-topics.sh --create --replication-factor 2 --partitions 1 --topic test - ...
kafka创建topic出现Replication factor: 1 larger than available brokers: 0.
项目场景: 安装好kafka之后, 准备建立一个topic出现Replication factor: 1 larger than available brokers: 0. 问题描述: 在安装好kaf ...

kafka创建Topic的一道面试题

kafka创建Topic的一道面试题相关推荐

最新文章

热门文章