Kafka - 专题

投稿

Kafka

收录了8篇文章 · 2人关注

Kafka源码分析（八）消息发送可靠性——flush.messages
继续解答问题：Kafka怎么样才能不丢消息？考虑一种比较极端的情况，整个Kafka集群用的是同一路电源，在掉电的情况下，消息是有可能丢失的，即...

0.3 81e2cd2747f1 0 3
Kafka源码分析（七）消息发送可靠性——min.insync.replicas
继续解答问题：Kafka怎么样才能不丢消息？再次说明下acks的语义如果acks=all，代表消息需要在所有ISR都被持久化成功后，Broke...

0.3 81e2cd2747f1 0 4

Kafka源码分析（六）消息发送可靠性——acks
接下去几篇关于可靠性的文章全部只讨论一个经典问题：Kafka怎么样才能不丢消息？怎么样的情况叫做丢消息？客户端调用future = send(...

0.1 81e2cd2747f1 0 1
Kafka源码分析（二）Arthas调试Kafka
在查看Kafka的方法调用时，断点调试与日志打印会显得非常重，如果学会了用Arthas这个武器，会让你探索Kafka的源码变得相对容易。场景一...

0.2 81e2cd2747f1 0 2
Kafka源码分析（四）高吞吐核心——RecordAccumulator消息发送过程
上一篇文章讲的是在主线程，消息在调用了send后，消息内容和该消息关联的future对象被一起放入了RecordAccumulator中，fut...

0.1 81e2cd2747f1 0 1
Kafka源码分析（三）高吞吐核心——RecordAccumulator消息累积过程
Kafka为什么会有这么高吞吐？ Kafka的发送逻辑和TCP的像极了，当客户端调用了producer.send(msg)后，Kafka的主线程...

81e2cd2747f1 0 0
Kafka源码分析（五）Kafka Broker逻辑骨架分析
阅读目标：从Kafka复杂的源码中找到初始阅读源码的突破口，然后简单分析下Broker是如何处理生产者发送的消息。 Broker和Client（...

0.1 81e2cd2747f1 0 1

Kafka源码分析（一） Intellij Idea 环境搭建
阅读目标：在Intellij IDEA中断点调试由scala描述的Kafka源码，并且控制台可以输出日志。将log4j配置文件放入maven工...

81e2cd2747f1 0 0