前言
在上文 设计一个百万级的消息推送系统 中提到消息流转采用的是 Kafka 作为中间件。
其中有朋友咨询在大量消息的情况下 Kakfa 是如何保证消息的高效及一致性呢？
正好以这个问题结合 Kakfa 的源码讨论下如何正确、高效的发送消息。
内容较多，对源码感兴趣的朋友请系好安全带
从源码分析如何优雅的使用 Kafka 生产者
2019-06-01
760
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《
阿里云开发者社区用户服务协议》和
《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写
侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：
前言在上文 设计一个百万级的消息推送系统 中提到消息流转采用的是 Kafka 作为中间件。其中有朋友咨询在大量消息的情况下 Kakfa 是如何保证消息的高效及一致性呢？正好以这个问题结合 Kakfa 的源码讨论下如何正确、高效的发送消息。
目录
相关文章
|
1月前
|
消息中间件
大数据
Kafka
|
1月前
|
消息中间件
缓存
Java
|
1月前
|
消息中间件
缓存
Kafka
|
1月前
|
消息中间件
存储
负载均衡
|
1月前
|
消息中间件
分布式计算
Java
|
1月前
|
消息中间件
存储
负载均衡
Kafka【付诸实践 01】生产者发送消息的过程描述及设计+创建生产者并发送消息（同步、异步）+自定义分区器+自定义序列化器+生产者其他属性说明（实例源码粘贴可用）【一篇学会使用Kafka生产者】
【2月更文挑战第21天】Kafka【付诸实践 01】生产者发送消息的过程描述及设计+创建生产者并发送消息（同步、异步）+自定义分区器+自定义序列化器+生产者其他属性说明（实例源码粘贴可用）【一篇学会使用Kafka生产者】
325
4
4
|
12天前
|
消息中间件
Kafka
|
18天前
|
消息中间件
存储
Kafka
|
18天前
|
消息中间件
存储
Kafka
|
1月前
|
消息中间件
缓存
安全
热门文章
最新文章
1
解决kafka集群由于默认的__consumer_offsets这个topic的默认的副本数为1而存在的单点故障问题
2
Kafka项目实战－用户日志上报实时统计之编码实践
3
7.【kafka运维】 kafka-consumer-groups.sh消费者组管理
4
05【在线日志分析】之Kafka 0.10.1.0 Cluster的搭建和Topic简单操作实验
5
在Windows系统上安装消息队列kafka
6
Kafka 3.0重磅发布，弃用 Java 8 的支持！
7
kafka 动态扩容现有 topic 的分区数和副本数
8
每年 150 亿美元花哪了？Netflix 的大规模 Kafka 实践
9
初识Kafka：构架、生产消费模型以及其他相关概念
10
Kafka SparkStreaming 保证数据不丢失问题 >0.10版本
1
SparkStreaming（SparkStreaming概述、入门、Kafka数据源、DStream转换、输出、关闭）
65
2
Kafka【付诸实践 03】Offset Explorer Kafka 的终极 UI 工具安装+简单上手+关键特性测试（一篇学会使用 Offset Explorer）
410
3
Kafka【付诸实践 02】消费者和消费者群组+创建消费者实例+提交偏移量（自动、手动）+监听分区再平衡+独立的消费者+消费者其他属性说明（实例源码粘贴可用）【一篇学会使用Kafka消费者】
108
4
Kafka【付诸实践 01】生产者发送消息的过程描述及设计+创建生产者并发送消息（同步、异步）+自定义分区器+自定义序列化器+生产者其他属性说明（实例源码粘贴可用）【一篇学会使用Kafka生产者】
325
5
Kafka【基础知识 02】集群+副本机制+数据请求+物理存储+数据存储设计（图片来源于网络）
69
6
Kafka【基础知识 01】消息队列介绍+Kafka架构及核心概念（图片来源于网络）
149
7
Kafka【问题记录 01】kill -9 导致 Kakfa 重启失败问题处理（doesn‘t match stored clusterId xxx in meta.properties）
46
8
Flink CDC产品常见问题之用upsert的方式写入kafka失败如何解决
98
9
Flink CDC产品常见问题之Flink CDC里从kafka消费的时候顺序混乱如何解决
91
10
DataWorks常见问题之kafka数据导入datahub失败如何解决
104