云消息队列 Kafka 版跟我学的相关内容

文章 2022-05-30 来自：开发者社区

跟我学Kafka:如何高效运维之主题篇

1、Kafka topic运维命令的基本使用Kafka提供了kafka-topics脚步用来创建、修改、删除、查询topic，位于${kafka_home}/bin/kafka-topics.sh，其中kafka_home表示Kafka的安装目录。接下来对一些上述一些不那么直观的选项进行单独介绍。1.1 --replica-assignment收到指定副本数量和分区信息，该参数不能和--part....

文章 2017-05-19 来自：开发者社区

跟我学Kafka之NIO通信机制

很久没有做技术方面的分享了，今天闲来有空写一篇关于Kafka通信方面的文章与大家共同学习。一、Kafka通信机制的整体结构这个图采用的就是我们之前提到的SEDA多线程模型，链接如下：http://www.jianshu.com/p/e184fdc0ade4 1、对于broker来说，客户端连接数量有限，不会频繁新建大量连接。因此一个Acceptor thread线程处理新建连接绰绰有余...

文章 2016-02-21 来自：开发者社区

跟我学Kafka之Controller控制器详解（一）

我们的kafka源码分享已经进行过很多期了，主要的内容也都分享的差不多了，那么那么在今后的分享中，主要集中在kafka性能优化和使用 Kafka集群中的其中一个Broker会被选举为Controller，主要负责Partition管理和副本状态管理，也会执行类似于重分配Partition之类的管理任务。如果当前的Controller失败，会从其他正常的Broker中重新选举Controller.....

文章 2016-02-18 来自：开发者社区

跟我学Kafka之zookeeper的存储结构

一、zookeeper存储结构总图图片当我们kafka启动运行以后，就会在zookeeper上初始化kafka相关数据，主要包括六大类： consumers admin config controller brokers controller_epoch 1、brokers节点结构说明 1.1 topic信息结构 /brokers/topics/[topic] : 存储某...

文章 2016-02-01 来自：开发者社区

跟我学Kafka之NIO通信机制

很久没有做技术方面的分享了，今天闲来有空写一篇关于Kafka通信方面的文章与大家共同学习。一、Kafka通信机制的整体结构 74EACA88-8B9D-45F8-B7BF-202D658205A9.png 这个图采用的就是我们之前提到的SEDA多线程模型，链接如下：http://www.jianshu.com/p/e184fdc0ade4 1、对于broker来说，客户端连接数...

文章 2015-12-29 来自：开发者社区

跟我学Kafka源码Producer分析

我的原文博客地址是：http://flychao88.iteye.com/blog/2266611 本章主要讲解分析Kafka的Producer的业务逻辑，分发逻辑和负载逻辑都在Producer中维护。一、Kafka的总体结构图 (图片转发）二、Producer源码分析 class Producer[K,V](val config: ProducerConfig, privat...

文章 2015-12-09 来自：开发者社区

跟我学Kafka源码使用入门（三）

这一节咱们主要是讨论单机版的Kafka的简单使用，关于集群方面的东西其实也非常简单，具体可以参考Kafka官网进行配置既可。 1、准备Zookeeper环境我们使用的是zookeeper-3.5.0版本。使用./zkServer.sh start命令启动Zookeeper 使用ps -ax | grep zookeeper命令，出现下图所示： 2、准备Kafka环境我们使用的...

文章 2015-12-09 来自：开发者社区