首页
个人开发
工作相关
共享
搜索
登录
搜索
colo
欲买桂花同载酒
累计撰写
1823
篇文章
累计收到
0
条评论
首页
栏目
首页
个人开发
工作相关
共享
Kafka原理
2025-12-12
如何设计高可靠的Kafka生产者与消费者系统以保障金融交易场景下的Exactly-Once语义？
实现金融级Exactly-Once语义需结合以下核心机制：生产者端：启用幂等发送（enable.idempotence=true）和事务API（transactional.id）Broker端：配置min.insync.replicas≥2并配合ISR机制保障数据持久化消费者端：使用事务型消费者配合isolation.level=read_committed系统设计：实现跨分区原子写入和消费者偏移量事务提交
2025年-12月-12日
4 阅读
0 评论
Kafka原理
2025-12-11
Kafka中的Topic和Partition有什么作用？
Topic是Kafka中消息的逻辑分类，Partition是Topic的物理分片，主要作用包括：Topic：定义消息类别，生产者/消费者基于Topic通信Partition：提升并发处理能力（多个消费者可同时读取不同Partition）实现水平扩展（数据分散存储在不同Broker）保证消息顺序性（同一Partition内消息有序）
2025年-12月-11日
4 阅读
0 评论
Kafka原理
2025-12-7
如何配置Kafka实现端到端的Exactly-Once消息传递？
实现Exactly-Once需要以下核心配置：生产者端：启用幂等性（enable.idempotence=true）和事务（transactional.id）Broker端：确保min.insync.replicas≥2且acks=all消费者端：设置isolation.level=read_committed并启用事务消费完整流程需配合事务API：初始化事务→发送消息→提交/中止事务。
2025年-12月-7日
4 阅读
0 评论
Kafka原理
2025-12-6
Kafka如何保证消息不丢失？
Kafka通过多级保障机制确保消息不丢失：生产者端：使用acks=all配置，要求所有ISR副本确认写入Broker端：设置min.insync.replicas≥2，启用副本同步机制消费者端：手动提交偏移量，避免自动提交导致的数据丢失存储层：配置unclean.leader.election.enable=false防止数据不一致
2025年-12月-6日
2 阅读
0 评论
Kafka原理
