分布式發布-訂閱消息系統 Apache Kafka v0.10.0.1-rc1發布

Apache Kafka是分布式發布-訂閱消息系統，原本開發自 LinkedIn，用作 LinkedIn 的活動流（Activity Stream）和運營數據處理管道（Pipeline）的基礎。之后成為Apache項目的一部分。 現在它已被多家公司作為多種類型的數據管道和消息系統使用。活動流數據是幾乎所有站點在對 其網站使用情況做報表時都要用到的數據中最常規的部分。Kafka是一種快速、可擴展的、設計內在就是分布式的，分區的和可復制的提交日志服務。

Apache Kafka與傳統消息系統相比，有以下不同：

• 它被設計為一個分布式系統，易于向外擴展；
• 它同時為發布和訂閱提供高吞吐量；
• 它支持多訂閱者，當失敗時能自動平衡消費者；
• 它將消息持久化到磁盤，因此可用于批量消費，例如ETL，以及實時應用程序。

更新日志

• [KAFKA-2068] - Replace OffsetCommit Request/Response with org.apache.kafka.common.requests equivalent
• [KAFKA-2069] - Replace OffsetFetch request/response with their org.apache.kafka.common.requests equivalent
• [KAFKA-2070] - Replace OffsetRequest/response with ListOffsetRequest/response from org.apache.kafka.common.requests
• [KAFKA-2071] - Replace Produce Request/Response with their org.apache.kafka.common.requests equivalents
• [KAFKA-2072] - Add StopReplica request/response to o.a.k.common.requests and replace the usage in core module
• [KAFKA-2073] - Replace TopicMetadata request/response with o.a.k.requests.metadata
• [KAFKA-2370] - Add pause/unpause connector support
• [KAFKA-2422] - Allow copycat connector plugins to be aliased to simpler names
• [KAFKA-2479] - Add CopycatExceptions to indicate transient and permanent errors in a connector/task
• [KAFKA-2508] - Replace UpdateMetadata{Request,Response} with org.apache.kafka.common.requests equivalent
• [KAFKA-2509] - Replace LeaderAndIsr{Request,Response} with org.apache.kafka.common.network.requests equivalent
• [KAFKA-2591] - Remove Persistent Data before Restoringafter a Fault
• 更多日志

下載

• Source code (zip)
• Source code (tar.gz)
• 官方下載