分布式发布-订阅消息系统 Apache Kafka v0.10.0.1-rc1发布

   <p style="text-align: center;"><img alt="" src="https://simg.open-open.com/show/a47ea349e1b790116c4a28e64a192461.png" /></p>    <p>Apache Kafka是分布式发布-订阅消息系统，原本开发自 LinkedIn，用作 LinkedIn 的活动流（Activity Stream）和运营数据处理管道（Pipeline）的基础。之后成为Apache项目的一部分。 现在它已被多家公司作为多种类型的数据管道和消息系统使用。活动流数据是几乎所有站点在对 其网站使用情况做报表时都要用到的数据中最常规的部分。Kafka是一种快速、可扩展的、设计内在就是分布式的，分区的和可复制的提交日志服务。</p>    <p>Apache Kafka与传统消息系统相比，有以下不同：</p>    <ul>     <li>它被设计为一个分布式系统，易于向外扩展；</li>     <li>它同时为发布和订阅提供高吞吐量；</li>     <li>它支持多订阅者，当失败时能自动平衡消费者；</li>     <li>它将消息持久化到磁盘，因此可用于批量消费，例如ETL，以及实时应用程序。</li>    </ul>    <p style="text-align: center;"><img alt="" src="https://simg.open-open.com/show/416db5f282cf16259bc59ba674ecf321.png" /><img src="file:///C:/Users/wqm/AppData/Local/Temp/enhtmlclip/Image(7).png" /></p>    <h2>更新日志</h2>    <ul>     <li>[<a href="/misc/goto?guid=4958990673001283011">KAFKA-2068</a>] - Replace OffsetCommit Request/Response with org.apache.kafka.common.requests equivalent</li>     <li>[<a href="/misc/goto?guid=4958990673100972831">KAFKA-2069</a>] - Replace OffsetFetch request/response with their org.apache.kafka.common.requests equivalent</li>     <li>[<a href="/misc/goto?guid=4958990673201434627">KAFKA-2070</a>] - Replace OffsetRequest/response with ListOffsetRequest/response from org.apache.kafka.common.requests</li>     <li>[<a href="/misc/goto?guid=4958990673295562186">KAFKA-2071</a>] - Replace Produce Request/Response with their org.apache.kafka.common.requests equivalents</li>     <li>[<a href="/misc/goto?guid=4958990673391009023">KAFKA-2072</a>] - Add StopReplica request/response to o.a.k.common.requests and replace the usage in core module</li>     <li>[<a href="/misc/goto?guid=4958990673486797081">KAFKA-2073</a>] - Replace TopicMetadata request/response with o.a.k.requests.metadata</li>     <li>[<a href="/misc/goto?guid=4958990673577248574">KAFKA-2370</a>] - Add pause/unpause connector support</li>     <li>[<a href="/misc/goto?guid=4958990673668998110">KAFKA-2422</a>] - Allow copycat connector plugins to be aliased to simpler names</li>     <li>[<a href="/misc/goto?guid=4958990673776536813">KAFKA-2479</a>] - Add CopycatExceptions to indicate transient and permanent errors in a connector/task</li>     <li>[<a href="/misc/goto?guid=4958990673865205190">KAFKA-2508</a>] - Replace UpdateMetadata{Request,Response} with org.apache.kafka.common.requests equivalent</li>     <li>[<a href="/misc/goto?guid=4958990673958192552">KAFKA-2509</a>] - Replace LeaderAndIsr{Request,Response} with org.apache.kafka.common.network.requests equivalent</li>     <li>[<a href="/misc/goto?guid=4958990674075864728">KAFKA-2591</a>] - Remove Persistent Data before Restoringafter a Fault</li>     <li><a href="/misc/goto?guid=4958992840964761728">更多日志</a></li>    </ul>    <h2>下载</h2>    <ul>     <li><a href="/misc/goto?guid=4958992841052567628" rel="nofollow"><strong>Source code</strong> (zip)</a></li>     <li><a href="/misc/goto?guid=4958992841166085792" rel="nofollow"><strong>Source code</strong> (tar.gz)</a></li>     <li><a href="/misc/goto?guid=4958852734958475727">官方下载</a></li>    </ul>    <p> </p>