グループへ属していないのでオフセットが保存されず、実行の度に上記のような出力となります。キーの入力で終了するようにできます。簡単に実施できるようになっています。取得したチャネルからメッセージを受信できます。使ってオフセットを保存します。接続して動作確認してみます。クライアント(上記サンプル)を複数実行し、メッセージの分散受信を試してみます。増やしても分散の効果はありません。そこで、まずはパーティション数を増やしておきます。変更後のパーティション数を指定します。3つ実行して、メッセージをいくつか送信してみたところ、以下のような結果となりました。見るとそれぞれのクライアントへ割り当てられているパーティションが変化している事を確認できます。