Kafkatopicleader均衡(about:blank%E8%83%8C%E6%99%AF"背景")背景在创建一个topic时，partition会在Br

基于某些原因，许多开发者会把这两种技术当做等价的来看待。的确，在一些案例场景下选择RabbitMQ还是Kafka没什么差别，但是这两种技术在底层实现方面是有许多差异的。\TOC\一、异步消息模式异步消息可以作为解耦消息的生产和处理的一种解决方案(DMP系统上使用较少，解耦是通过分布式服务构成的，这两种方式各有利弊，后面有机会再说)。

这部分内容对了解系统和提高软件性能都有很大的帮助，kafka官网上也给出了比较详细的配置详单，但是我们还是直接从代码来看broker到底有哪些配置需要我们去了解的，配置都有英文注释，所以每一部分是干什么的就不翻译了，都能看懂：/LicensedtotheApacheSoftwareFoundation(ASF)u

 因为kafka配置较多，所以单独写一篇博客来记录。       1，broker配置   主要的配置项有三个broker.id集群内唯一log.dir数据目录zookeeper.connectzookeeper连接地址Topiclevelconfigurationsanddefaultsa

最近在测试kafka性能的时候特别对kafka的producer端进行了一些扩展，本想着针对多个业务开发多个producer进行并行的生产数据，并通过统一的线程池进行管理，结果在用jconsole进行观察的时候，发现线程数一路飙升。本以为一个简单的发送端程序却花了不少精力。造成线程上涨的主要原因是有两个线程对象不断的被创建，并且暂时无法销毁。一个叫sen

上一篇文章讲了LogSegment和Log的初始化，这篇来讲讲Log的主要操作有哪些。一般来说Log的常见操作分为4大部分。1.高水位管理操作2.日志段管理3.关键位移值管理4.读写操作其中关键位移值管理主要包含LogStartOffset和LEO等。高水位HighWatermark

本文首发于vivo互联网技术微信公众号https://mp.weixin.qq.com/s/bV8AhqAjQp4a\_iXRfobkCQ(https://www.oschina.net/action/GoToLink?urlhttps%3A%2F%2Fmp.weixin.qq.com%2Fs%2FbV8AhqAjQp4a_iXRfobkCQ

1\.CAP理论　　1.1Cosistency(一致性)　　通过某个节点的写操作结果对后面通过其他节点的读操作可见。　　如果更新数据后，并发访问的情况下可立即感知该更新，称为强一致性　　如果允许之后部分或全部感知不到该更新，称为弱一致性。　　若在之后的一段时间（通常该时间

ApacheKafka®是_一个分布式流处理平台_.这到底意味着什么呢?我们知道流处理平台有以下三种特性:可以让你发布和订阅流式的记录。这一方面与消息队列或者企业消息系统类似。可以储存流式的记录，并且有较好的容错性。可以在流式记录产生时就进行处理。Kafka适合什么样的场

1\.PullvsPush　　Producer主动的通过push将消息发布到Broker上，Consumer通过Pull的的方式从Broker消息消息。　　通过Push的方式由于是一有消息就推到Broker,所以极大的保证了消息实时性，但是在某些情况下，可能由于Consumer网络，或是其他原因倒是消费速度低，