Apache Kafka 0.8 -> 0.9 変更点 - Bathynomus giganteus経緯 Apache Kafka 0.9.0.0の変更点を調べていて、日本語でまとめられた記事が見当たらなかったので、自分用に備忘がてら http://kafka.apache.org/documentation.html#upgrade_9_breaking の内容をまとめてみました。 ※ 拙い英語力で調べていますので、誤っている可能性が多々あります。 後方互換性の無い変更 Java 1.6 はサポート外に。 Scala 2.9 はサポート外に。 1000を超えるbroker IDが自動的にbroker IDを割り当てるためにデフォルトで予約されている。クラスタがその閾値を超えようとする場合、それに応じて reserved.broker.max.id を増加するようbrokerを構成する。 replica.lag.max.messagesを削除。パーティションのリーダーは遅延したメッセージ
