kafka专栏

kafka 源码、原理、实战、视频 视频录制首发在公众号: 石臻臻的杂货铺 个人v: jjdlmn_
135 篇文章
16.7K 次阅读
28 人订阅

全部文章

石臻臻的杂货铺[同名公众号]

【kafka思考】最小成本的扩缩容副本设计方案

从【kafka源码】kafka分区副本的分配规则 中我们已经知道了,如何分区副本是如何进行分配的 那么当我们想要批量进行副本扩缩的时候, 如果按照之前 --g...

6430
石臻臻的杂货铺[同名公众号]

《kafka问答100例 -5》什么时候真正执行删除Topic磁盘日志 ?

3610
石臻臻的杂货铺[同名公众号]

《kafka面试100例 -6》如果在/admin/delete_topics/中手动写入一个节点会不会正常删除Topic

如果在/admin/delete_topics/中手动写入一个节点会不会正常删除Topic ?

6540
石臻臻的杂货铺[同名公众号]

《kafka问答100例 -7》如果Topic删除过程中有某台Broker宕机,删除流程会正常进行吗 ?

但是,只要某台Broker里的任意分区副本没有被正常删除(被标记了–delete)的话, 那么整个删除流程是没有结束的; 这个阻塞过程中Topic处于一个不可...

5840
石臻臻的杂货铺[同名公众号]

Kafka如何修改分区Leader | 文末送书8本

前几天有个群友问我: kafka如何修改优先副本? 他们有个需求是, 想指定某个分区中的其中一个副本为Leader

5010
石臻臻的杂货铺[同名公众号]

【kafka源码】/log_dir_event_notification的LogDir脱机事件通知

这里说的dirLog是 server.properties中配置的log.dir 例如

7450
石臻臻的杂货铺[同名公众号]

《kafka问答100例 -4》 如果我手动在zk中添加/brokers/topics/{TopicName}节点会怎么样?

如果我手动在zk中添加`/brokers/topics/{TopicName}`节点会怎么样?

4410
石臻臻的杂货铺[同名公众号]

《kafka问答100例 -1》 kafka创建Topic的时候 在Zk上创建了哪些节点

「1 / 100」 kafka创建Topic的时候 在Zk上创建了哪些节点?

5030
石臻臻的杂货铺[同名公众号]

《kafka问答100例 -2》 创建Topic的时候 什么时候在Broker磁盘上创建的日志文件

Topic创建流程深度解析请看下文 ???????? 创建Topic的源码解析 ????

7560
石臻臻的杂货铺[同名公众号]

一图全解Kafka在zookeeper中的数据结构

4730
石臻臻的杂货铺[同名公众号]

Mac提升工作效率从Alfred神器开始(上)

最近公司发了新Mac,又要重新装各种软件,问了一圈身边的人发现,居然还有这么多人不知道Alfred这款神器,我表示非常震惊,因为使用Mac不用这款Alfred神...

8220
石臻臻的杂货铺[同名公众号]

关于配置,你必须要知道这一点....

今天这篇文章,给大家分享一下最近看kafka中的动态配置,不需要重启Broker,即时生效的配置 欢迎留言一起探讨!

5120
石臻臻的杂货铺[同名公众号]

【kafka源码】kafka分区副本的分配规则

从源码中得知, 会把我们指定的规则进行了包装,注意它并没有去检查你指定的Broker是否存在;

5320
石臻臻的杂货铺[同名公众号]

这个bug,你中招了吗!!!

今天这篇文章,给大家分享一下最近看kafka源码时候,困扰我几天的疑惑,供大家一起思考讨论,确定一下它是不是一个 Bug 欢迎留言一起探讨!

14672
石臻臻的杂货铺[同名公众号]

8.【kafka运维】kafka-dump-log.sh消费者组管理

配置项为log.index.size.max.bytes; 来控制创建索引的大小;

7250
石臻臻的杂货铺[同名公众号]

万字长文解析删除Topic流程领导再也不用担心我排查生产环境问题了(附教学视频,建议收藏!!!)

支持正则表达式匹配Topic来进行删除,只需要将topic 用双引号包裹起来 例如: 删除以create_topic_byhand_zk为开头的topic;

10220
石臻臻的杂货铺[同名公众号]

7.【kafka运维】 kafka-consumer-groups.sh消费者组管理

先调用MetadataRequest拿到所有在线Broker列表 再给每个Broker发送ListGroupsRequest请求获取 消费者组数据

19510
石臻臻的杂货铺[同名公众号]

创建Topic原来还能这样玩,真绝了!!!(附视频)

需要注意的是–zookeeper后面接的是kafka的zk配置, 假如你配置的是localhost:2181/kafka 带命名空间的这种,不要漏掉了

10020
石臻臻的杂货铺[同名公众号]

6.【kafka运维】删除Topic消息+查看Broker磁盘信息

从这里可以看出来,配置"offset": 1024 的意思是从最开始的地方删除消息到 1024的offset; 是从最前面开始删除的

9120
石臻臻的杂货铺[同名公众号]

5.【kafka运维】生产者消费组压力测试运维(5)

1. 发送1024条消息--num-records 100并且每条消息大小为1KB--record-size 1024 最大吞吐量每秒10000条--throu...

6830

扫码关注云+社区

领取腾讯云代金券