最近在用kafka作为消费队列，看的网上对分区的工作原理都是文字描述比较多，所以特地画了简图分享出来

微信公众号「后端进阶」，专注后端技术分享：Java、Golang、WEB框架、分布式中间件、服务治理等等。

从上面的架构图可以看出，生产的流程主要就是一个producer线程和一个sender线程，它们之间通过BatchQueue来获取数据，它们的关系是一一对应的，所以kafka的生产过程都是异步过程，它的同步和异步指的是接收响应结…

刚才午睡了一会，做了一个梦，Kafka为什么”这么快”，于是乎，便写了这篇探讨的博客文章，网上很多关于Kafka测试的文章，测试结果通常都是Kafka延迟吊打其他MQ，那么我们学习一个新东西的时候，首先会想到它会在我…

上周六在深圳分享了《Flink SQL 1.9.0 技术内幕和最佳实践》，会后许多小伙伴对最后演示环节的 Demo 代码非常感兴趣，迫不及待地想尝试下，所以写了这篇文章分享下这份代码。希望对于 Flink SQL 的初学者能有所帮…

「K8S 生态周报」内容主要包含我所接触到的 K8S 生态相关的每周值得推荐的一些信息。欢迎订阅知乎专栏「k8s生态」。

flink是一款开源的大数据流式处理框架，他可以同时批处理和流处理，具有容错性、高吞吐、低延迟等优势，本文简述flink在windows和linux中安装步骤，和示例程序的运行。

​ Kafka是由LinkIn开源的实时数据处理框架，目前已经更新到2.3版本。不同于一般的消息中间件，Kafka通过数据持久化和磁盘读写获得了极高的吞吐量，并可以不依赖Storm，SparkStreaming的流处理平台，自己进行实时…

Springboot系列之kafka操作 kafka简介 ApacheKafka®是一个分布式流媒体平台。有三个关键功能： {代码…} Kafka通常用于两大类应用： {代码…} kafka概念 （1）什么是流处理？ {代码…} （2）partition和replic…

“””Author:YjxTime:2019-8-17 14:22″””from kafka import KafkaProducerfrom kafka import KafkaConsumerfrom kafka.errors import KafkaErrorfrom threading import Threadimport time