需要注意的是 , 由于 TLS/SSL 库是工作在用户空间的,所以,当启用了 SSL,sendfile 将不能使用 。
基于分区的横向扩展关于这一点,在上一篇博客中其实已经提到过 。首先,一个 topic 会划分成一个或多个 partition,这些 partition 一般分布在不同的 broker 实例 。producer 发布的 event 会根据某种策略分配到不同的 partition,这样做的好处是,consumer 可以同时从多台 broker 读取 event,从而大大提高吞吐量 。另外 , 为了高可用,同一个 partition 还会有多个副本,它们分布在不同的 broker 实例,和很多传统的消息系统不同,Kafka 的副本是可读的,即 consumer 不仅可以从主 partition 读取 event,也可以从副本读取 。//zzs001
文章插图
结语以上内容是最近学习 Kafka 的一些思考和总结(主要参考官方文档),如有错误,欢迎指正 。
任何的事物 , 都可以被更简单、更连贯、更系统地了解 。希望我的文章能够帮到你 。
最后,感谢阅读 。
参考资料Apache Kafka 官方文档
Benchmarking Kafka vs. Pulsar vs. RabbitMQ: Which is Fastest?
The OpenMessaging Benchmark Framework
The Pathologies of Big Data - ACM Queue
Efficient data transfer through zero copy - IBM Developer
相关源码请移步:https://github.com/ZhangZiSheng001/kafka-demo
本文为原创文章,转载请附上原文出处链接:https://www.cnblogs.com/ZhangZiSheng001/p/16788561.html
推荐阅读
- subprocess Python编程之子进程管理详解
- 二 路径分析—PostgreSQL+GeoServer+Openlayers
- CentOS 7.9 安装 kafka_2.13
- 电锯人第二集在哪可以看
- 二 SpringBoot - 核心配置文件
- .NET 采用 SkiaSharp 生成二维码和图形验证码及图片进行指定区域截取方法实现
- 【算法训练营day1】LeetCode704. 二分查找 LeetCode27. 移除元素
- AVX图像算法优化系列二: 使用AVX2指令集加速查表算法。
- 详解商业智能“前世今生”,“嵌入式BI”到底是如何产生的?
- LinkedBlockingQueue详解