继续解答问题:Kafka怎么样才能不丢消息? 考虑一种比较极端的情况,整个Kafka集群用的是同一路电源,在掉电的情况下,消息是有可能丢失的,即便消息已经被复制所有的ISR上...
继续解答问题:Kafka怎么样才能不丢消息? 再次说明下acks的语义如果acks=all,代表消息需要在所有ISR都被持久化成功后,Broker才可以告诉生产者,消息已经发...
接下去几篇关于可靠性的文章全部只讨论一个经典问题:Kafka怎么样才能不丢消息? 怎么样的情况叫做丢消息?客户端调用future = send(msg, callback),...
上一篇文章讲的是在主线程,消息在调用了send后,消息内容和该消息关联的future对象被一起放入了RecordAccumulator中,future对象最终被send方法返...
Kafka为什么会有这么高吞吐? Kafka的发送逻辑和TCP的像极了,当客户端调用了producer.send(msg)后,Kafka的主线程并不会着急直接调用网络底层将消...
由于 mac high sierra 系统有较大的变动,所以专门写一篇用mac high sierra 来编译 openjdk8 的博客. 准备阶段 mac 系统版本 10...
亲,RMQ可以实现分布式事务的,建议你先去体验下rocketmq-4.3.0中关于事务的例子,然后再来看一遍这篇文章,理解会好很多。
构建基于RocketMQ的分布式事务服务说在前面 Apache RocketMQ-4.3.0正式Release了事务消息的特性,顺着最近的这个热点。第一篇文章,就来聊一下在软件工程学上的长久的难题——分布式事务(D...
[TOC] 简介 kafka是一个分布式消息队列。具有高性能、持久化、多副本备份、横向扩展能力。生产者往队列里写消息,消费者从队列里取消息进行业务逻辑。一般在架构设计中起到解...
在查看Kafka的方法调用时,断点调试与日志打印会显得非常重,如果学会了用Arthas这个武器,会让你探索Kafka的源码变得相对容易。 场景一 我知道接下来,kafka一定...
@wj121 谢谢,相互学习,如果觉得还不错,请帮忙推广下,我最近开始写一些其它专题了
构建基于RocketMQ的分布式事务服务说在前面 Apache RocketMQ-4.3.0正式Release了事务消息的特性,顺着最近的这个热点。第一篇文章,就来聊一下在软件工程学上的长久的难题——分布式事务(D...
VSCode C++插件
/Users/ericfei/Code/opensource/openjdk-jdk12u/src/hotspot/share/runtime/thread.cpp