Apache Kafka

の Apacheのカフカの（あなたがそれに慣れている場合）、アクティビティストリームを処理するために使用することができますFacebookのスクライブエンジンに似ています。

これは、開発者が一つ以上のアクティビティストリーム（またはフィード）を維持することを可能にすることによって機能します。

これらのフィードは、すべてのサブスクライブしているコンシューマに（公開）のトピックで構成してから、ブロードキャストを行うことができます。

フィードを管理し、公開するカフカの部分は生産者と呼ばれています。

カフカは、基本的には、生産者と消費者の間の中間層、スケールのいずれかのタイプのトラフィックやリクエストの任意の種類を扱うことができる複雑なシステムである。

カフカは、開発者がクラウドサービス上でのパブ/サブシステムを拡張することができ、分散サーバ・アーキテクチャを処理するために建設されたためです。

<強い>新しいのは何でこのリリース：ます。

• 実装の容易さと性能向上のための新しいJavaプロデューサます。
• トピックのサポートを削除します。

可用性を一貫性のための好みのトピックの設定ごとに
• ます。
• スカラ2.11サポートとScalaの2.8のサポートを落とします。
• LZ4圧縮ます。

こののバージョン0.8.2.1:

• A新しいJava実装を容易にするための生産と強化のの新機能パフォーマンスます。
• トピックのサポートを削除します。

可用性を一貫性のための好みのトピックの設定ごとに
• ます。
• スカラ2.11サポートとScalaの2.8のサポートを落とします。
• LZ4圧縮ます。


• 固定既存PERFツールます。

  <強い>新しいのバージョンでは0.8.0-β1は何ですか。 >

• ワイヤー新しいZKのデータ構造を使用するには、既存の生産者と消費者ます。
• の作成/管理ツールのトピックのためのZKのパスを削除します。
• 実装組み込みコントローラます。

<強い>バージョン0.7.1の新のです何ます。

• 消費者のリバランス時に重複したメッセージを避けます。

サーバ内の
• サポート設定の送信/受信ソケットバッファサイズます。

<李は>のにJavaAPI ZookeeperConsumerConnectorTestはScalaのバージョンで多くのテストを複製します。
• 消費者のリバランスの＃は設定再試行してくださいます。

接続できない場合ます。
• SyncProducerは、ホストとポートを記録する必要があります
• 非圧縮トピックのカフカの消費者によって提供される重複メッセージを削減します。
• 直接ロギングスタックトレースを避けます。
• 消費者のリバランス時にバックオフ時間を作る、設定ます。
• kafka.producer.Producerを使用し、zk.connectをサポートするためのlog4jアペンダを改善| broker.listオプション
• スタンドアロンアプリにミラーリングカフカを分離ます。
• Hadoopのプロデューサーが使用するソフトウェアロードバランサます。

<強い>バージョン0.7.0のの新機能：

• カフカは現在、ブロック・レベルの圧縮をサポートしています。詳細については、圧縮Wikiを参照してください。現在、唯一のgzipが移植されたのsupされます。
• 今スペース（log.retention.size）に依存することができる保持を記録します。

<強い>バージョン0.6のの新機能：

• 修正されたバグ：
• SimpleProducerソケットはIO例外ます。
を取得したときにメッセージを失います
プロデューサーが無効MessageSetを送信した場合、
• ブローカーは
ログを破壊、それを追加します
• ByteBufferMessageSetサイズをフェッチに関するエラーをログに記録します。
• シャットダウンカフカ任意のディスクIOエラーがあります。
• サーバーの消費者へのすべての例外を伝播ます。
• SimpleConsumerでクローズ（）を同期させておく必要があります。
• コンシューマコードのドキュメント
• AsyncProducerでのEventHandlerを改善します。

農産物の要求にサービスを提供しながら、
• 飼育係ベースのプロデューサーは、そのリストから死んでブローカーを削除しません。

クローズ時に
• コンシューマログエラーます。
• 改良：
• クリーンアップJUnitテストます。
• MessageSetは、Javaを実装していない反復可能な
• カフカのデフォルトエンコーダlog4アペンダます。
• 明示的にすべてのスレッドに名前を付けます。
• JavaとScalaのAPIへのリファクタリングパブリックAPIます。
• すべてのパブリックAPIのAPIドキュメントを改善します。
• のjava FileMessageSet APIを削除します。
• ユニットテストは、いくつかのLinuxマシン上では失敗します。
• 現在使用しているPERF、例、contribのためのSBTサブプロジェクトを作成したAntます。
• カフカサーバに動的にlog4jのレベルを変更するためのJMXを追加します。
• 飼育係3.3.3ます。
へのアップグレード
• のにJavaAPI MessageSetのwriteToソケットを実装する必要はありません。
• 新機能：
• 新プロデューサーのAPIます。
10 Dec 15