-
编辑 删除
Kafka滥用案例
最近再做一个master-worker式的任务调度程序，这个第一版是同事做的，我负责重构。代码结构在这篇文章里之前使用kafka来做队列，但是当我重构时发现，worker处理一个message的时间有时候需要几分钟，处理完茶都凉了，consumer和partition的连接都断了，没法commit了
-
编辑 删除
仅需3分钟，你就能明白Kafka的工作原理
周末无聊刷着手机，某宝网App突然蹦出来一条消息“为了回馈老客户，女朋友买一送一，活动仅限今天！”。买一送一还有这种好事，那我可不能错过！忍不住立马点了去。于是选了两个最新款，下单、支付一气呵成！满足的躺在床上，想着马上有女朋友了，竟然幸福的失眠了……第二天正常上着班，突然接到快递小哥的电话：小哥：
-
编辑 删除
震惊了，原来这才是Kafka的“真面目”！
导读：Kafka是一个分布式消息队列，具有高性能、持久化、多副本备份、横向扩展能力。生产者往队列里写消息，消费者从队列里取消息进行业务逻辑。一般在架构设计中起到解耦、削峰、异步处理的作用。Kafka对外使用Topic的概念，生产者往Topic里写消息，消费者从中读消息。为了做到水平扩展，一个Topi
-
编辑 删除
Fabric基于Kafka的共识机制剖析
在HyperledgerFabric最新发布的1.0版本里，分拆出来Orderer组件用于交易的排序及共识。现阶段提供solo及kafka两种方式的实现。solo模式不用多讲，即整个集群就一个Orderer节点，区块链的交易顺序即为它收到交易的顺序。而kafka模式的Orderer相对较复杂，在实现
-
编辑 删除
读书 | 《Kafka 权威指南》
一句话评价：非常干，没有一句废话！本书的作者阵容非常强大，有Kafka的作者、经验丰富的架构师，还有专家级的SRE，让本书既深入代码原理，又兼顾介绍Kafka在整个数据系统中的作用，还提供了运维Kafka的宝贵经验。为什么说本书干货满满呢，拿第一章举例，一般书籍的简介部分会比较水，但本书不然，第一章
-
编辑 删除
十年阿里分布式架构师写了一份Kafka心得PDF，这也太详细了吧
初识KafkaKafka都有哪些特点？高吞吐量、低延迟：kafka每秒可以处理几十万条消息，它的延迟最低只有几毫秒，每个topic可以分多个partition,consumergroup对partition进行consume操作。可扩展性：kafka集群支持热扩展持久性、可靠性：消息被持久化到本地磁
-
编辑 删除
分布式消息队列RocketMQ与Kafka架构上的巨大差异
原文来自于CSDN【travi】在讲过几次kafka以后得到不错的反响，所以这篇文章，也是继续讲一讲kafka学习，给大家一个不错的反应我们知道，在早期的RocketMQ版本中，是有依赖ZK的。而现在的版本中，是去掉了对ZK的依赖，转而使用自己开发的NameSrv。并且这个NameSrv是无状态的，
-
编辑 删除
Kafka面试，看这一篇文章就够了
如需转载，务必在文章开头、结尾加粗如下内容：本文转自：靳刚同学Note：如果图片显示有问题，可关注：靳刚同学，获取正确格式的内容MQ（消息队列）是跨进程通信的方式之一，可理解为异步rpc，上游系统对调用结果的态度往往是重要不紧急。使用消息队列有以下好处：业务解耦、流量削峰、灵活扩展。接下来介绍消息中
-
编辑 删除
昨晚微信封了一批号
昨晚可能是不少做社群运营同学的噩梦，很多挂着wetool的微信收到提醒微信被临时限制登录，当然这个限制登录是多久，没有提醒。但是这算是微信的一次重要警告了，后面你再挂出事了就别来烦我了。1、Wetool是什么估计不少人不知道Wetool是何方神圣，我就简单跟大家介绍下：外行人可以简单理解为微信的外挂
-
编辑 删除
全网最通俗易懂的Kafka入门！
前言只有光头才能变强。文本已收录至我的GitHub仓库，欢迎Star：https://github.com/ZhongFuCheng3y/3y在这篇之前已经写过两篇基础文章了，强烈建议先去阅读：什么是ZooKeeper？什么是消息队列？众所周知，消息队列的产品有好几种，这里我选择学习Kafka的原因
-
编辑 删除
同事三面阿里，竟挂在了Kafka；哭诉让我帮他找份Kafka面试题
欢迎关注专栏《Java架构筑基》——专注于Java技术的研究与分享！Java架构筑基zhuanlan.zhihu.comJava架构筑基——专注于Java技术的研究与分享！后续文章将首发此专栏！欢迎各位Java工程师朋友投稿和关注1.什么是kafkaKafka是分布式发布-订阅消息系统，它最初是由
-
编辑 删除
同事三面阿里，竟挂在了Kafka；哭诉让我帮他找份Kafka面试题
欢迎关注专栏《Java架构筑基》——专注于Java技术的研究与分享！Java架构筑基zhuanlan.zhihu.comJava架构筑基——专注于Java技术的研究与分享！后续文章将首发此专栏！欢迎各位Java工程师朋友投稿和关注1.什么是kafkaKafka是分布式发布-订阅消息系统，它最初是由
-
编辑 删除
再过半小时，你就能明白kafka的工作原理了
为什么需要消息队列周末无聊刷着手机，某宝网APP突然蹦出来一条消息“为了回馈老客户，女朋友买一送一，活动仅限今天！”。买一送一还有这种好事，那我可不能错过！忍不住立马点了去。于是选了两个最新款，下单、支付一气呵成！满足的躺在床上，想着马上有女朋友了，竟然幸福的失眠了……第二天正常上着班，突然接到快递
-
编辑 删除
再过半小时，你就能明白kafka的工作原理了
为什么需要消息队列周末无聊刷着手机，某宝网APP突然蹦出来一条消息“为了回馈老客户，女朋友买一送一，活动仅限今天！”。买一送一还有这种好事，那我可不能错过！忍不住立马点了去。于是选了两个最新款，下单、支付一气呵成！满足的躺在床上，想着马上有女朋友了，竟然幸福的失眠了……第二天正常上着班，突然接到快递
-
编辑 删除
分布式学习(5) ---- 初识消息系统kafka
消息系统在分布式应用中有着不可或缺的地位，像是成产消费数据解耦，缓存未处理的消息等等。那为什么不学习用Java写的ActiveMQ或RabbitMQ呢？因为我看过卡夫卡写的变形记。简单原理图分布式消息系统就是生产者集群和消费者集群分离，通过中间的一个消息系统进行通信。生产者异步生产东西，不用管消费者
-
编辑 删除
Kafka史上最全入门宝典
初识Kafka.什么是KafkaKafka是由Linkedin公司开发的，它是一个分布式的，支持多分区、多副本，基于Zookeeper的分布式消息流平台，它同时也是一款开源的基于发布订阅模式的消息引擎系统。Kafka的基本术语消息：Kafka中的数据单元被称为消息，也被称为记录，可以把它看作数据库表
-
编辑 删除
Kafka的面试知识，都在这儿了
我们在《360度测试：KAFKA会丢数据么？其高可用是否满足需求？》这篇文章中，详细说明了KAFKA是否适合用在业务系统中。但有些朋友，还不知道KAFKA为何物，以及它为何存在。这在工作和面试中是比较吃亏的，因为不知道什么时候起，KAFKA似乎成了一种工程师的必备技能。一些观念的修正从0.9版本开始
-
编辑 删除
如何保证kafka消息不丢失
背景这里的kafka值得是broker,broker消息丢失的边界需要对齐一下：1已经提交的消息2有限度的持久化如果消息没提交成功，并不是broke丢失了消息；有限度的持久化（broker可用）生产者丢失消息producer.send(Objectmsg);这个发送消息的方式是异步的；fireand
-
编辑 删除
kafka可插拔增强如何实现？
导弹拦截，精准防御。背景拦截器：在不修改应用程序业务逻辑的情况下，一组基于事件的可插拔的逻辑处理链；类比springMVC的拦截器：这些都是通过配置拦截器，插入到应用程序中，实现可插拔的修改业务逻辑；kafka在0.10.0.0版本中开始引入拦截器。分为生产者拦截器和消费者拦截器，类似责任链的方式编
-
编辑 删除
杠上Spark、Flink？Kafka为何转型流数据平台
本文由「AI前线」原创（ID：ai-front），原文链接：杠上Spark、Flink？Kafka为何转型流数据平台策划编辑｜Natalie作者｜郭斯杰编辑｜DebraAI前线导读：消息中间件系统（比如RabbitMQ、Kafka、Pulsar等）是现代实时数据或者流数据基础架构的关键环节。它通常作
