12.2. ZooKeeper クラスターへのノードの追加
動的再設定 を使用して、クラスター全体を停止せずに ZooKeeper クラスターからノードを追加します。動的再設定を使用すると、ZooKeeper は、ZooKeeper クラスターを設定するノードのセットのメンバーシップを中断することなく変更できます。
前提条件
-
動的再設定が ZooKeeper 設定ファイル (
reconfigEnabled=true
) で有効になっている。 - ZooKeeper の認証が有効化され、認証メカニズムを使用して新しいサーバーにアクセスできる。
手順
追加する ZooKeeper サーバーごとに次の手順を 1 つずつ実行します。
- 「マルチノードの ZooKeeper クラスターの実行」 の説明に従ってサーバーを ZooKeeper クラスターに追加し、ZooKeeper を起動します。
- 新しいサーバーの IP アドレスと設定されたアクセスポートをメモします。
サーバーの
zookeeper-shell
セッションを開始します。クラスターにアクセスできるマシンから次のコマンドを実行します (アクセスできる場合は、ZooKeeper ノードまたはローカルマシンの 1 つである可能性があります)。su - kafka /opt/kafka/bin/zookeeper-shell.sh <ip-address>:<zk-port>
シェルセッションで、ZooKeeper ノードが実行されている状態で、次の行を入力して、新しいサーバーを投票メンバーとしてクォーラムに追加します。
reconfig -add server.<positive-id> = <address1>:<port1>:<port2>[:role];[<client-port-address>:]<client-port>
以下に例を示します。
reconfig -add server.4=172.17.0.4:2888:3888:participant;172.17.0.4:2181
<positive-id>
は、新しいサーバー ID4
です。2 つのポートの
<port1>
2888 は ZooKeeper サーバー間の通信用で、<port2>
3888 はリーダーエレクション用です。新しい設定は ZooKeeper クラスターの他のサーバーに伝播されます。新しいサーバーはクォーラムの完全メンバーになります。