Streams for Apache Kafka Console の使用

手順

1. コンソールのインストールアーティファクトをダウンロードして展開します。

   アーティファクトは、Streams for Apache Kafka ソフトウェアダウンロードページ から入手できるインストールおよびサンプルファイルに含まれています。

   アーティファクトは、Kafka クラスターをインストールするためのデプロイメント YAML ファイルを提供します。examples/console/resources/kafka にあるサンプルインストールファイルを使用します。

2. 環境変数を設定してインストールファイルを更新します。

   export NAMESPACE=kafka 

   1

   
   export LISTENER_TYPE=route 

   2

   
   export CLUSTER_DOMAIN=<domain_name> 

   3

   Copy to Clipboard Toggle word wrap

   1

   Kafka Operator をデプロイする namespace。

   2

   Kafka をコンソールに公開するために使用するリスナータイプ。

   3

   OpenShift クラスターのクラスタードメイン名。

   この例では、namespace 変数は kafka と定義されており、リスナータイプは route です。

3. Kafka クラスターをインストールします。

   次のコマンドを実行して、YAML ファイルを適用し、定義された namespace に Kafka クラスターをデプロイします。

   cat examples/console/resources/kafka/*.yaml | envsubst | kubectl apply -n ${NAMESPACE} -f -

   Copy to Clipboard Toggle word wrap

   このコマンドは、YAML ファイルを読み取り、namespace 環境変数を置き換え、結果として得られる設定を指定の OpenShift namespace に適用します。

4. デプロイメントのステータスを確認します。

   oc get pods -n kafka

   Copy to Clipboard Toggle word wrap

   出力には Operator とクラスターの準備状況が表示されます

   NAME                              READY   STATUS   RESTARTS
   strimzi-cluster-operator          1/1     Running  0
   console-kafka-console-nodepool-0  1/1     Running  0
   console-kafka-console-nodepool-1  1/1     Running  0
   console-kafka-console-nodepool-2  1/1     Running  0

   Copy to Clipboard Toggle word wrap

   • console-kafka はクラスターの名前です。

   • console-nodepool はノードプールの名前です。

     ノード ID は作成されたノードを識別します。

     デフォルトのデプロイメントでは、3 つのノードをインストールします。

     READY は、ready/expected 状態のレプリカ数を表示します。STATUS が Running と表示されれば、デプロイメントは成功です。

手順

1. OpenShift Web コンソールで Home > Projects ページに移動し、インストール用のプロジェクト (namespace) を作成します。

   この例では、streams-kafka-console という名前のプロジェクトを使用します。

2. Operators > OperatorHub ページに移動します。

3. ページをスクロールするか、Filter by keyword ボックスにキーワードを入力して、Streams for Apache Kafka Console Operator を見つけます。

   Operator は、Streaming & Messaging カテゴリーにあります。

4. Streams for Apache Kafka Console をクリックして、Operator の情報を表示します。
5. Operator に関する情報を確認し、Install をクリックします。

6. Install Operator ページで、次のインストールおよび更新オプションから選択します。

   • Update Channel: Operator の更新チャネルを選択します。

     • alpha チャネル (デフォルト) には最新の更新とリリースがすべて含まれます。これには、十分なテストを行った上、安定していることが想定される、メジャー、マイナー、およびマイクロリリースが含まれます。
     • amq-streams-X.x チャネルには、メジャーリリースのマイナーリリースの更新およびマイクロリリースの更新が含まれます。X は、メジャーリリースのバージョン番号に置き換えてください。
     • amq-streams-X.Y.x チャネルには、マイナーリリースのマイクロリリースの更新が含まれます。X はメジャーリリースのバージョン番号、Y はマイナーリリースのバージョン番号に置き換えてください。

   • Installation Mode: OpenShift クラスター内のすべての namespace に Operator をインストールします。

     単一の Operator インスタンスにより、OpenShift クラスター全体に作成されるコンソールが監視および管理されます。

   • Update approval: デフォルトでは、Streams for Apache Kafka Console Operator は、Operator Lifecycle Manager (OLM) によって最新のコンソールバージョンに自動的にアップグレードされます。今後のアップグレードを手動で承認する場合は、Manual を選択します。Operator の詳細は、OpenShift ドキュメント を参照してください。
7. Install をクリックして、選択した namespace に Operator をインストールします。

8. Operator を使用する準備ができたら、Operators > Installed Operators に移動して、Operator が選択した namespace にインストールされていることを確認します。

   ステータスは Succeeded と表示されます。

9. コンソール Operator を使用して コンソールをデプロイし、Kafka クラスターに接続 します。

手順

1. コンソールのインストールアーティファクトをダウンロードして展開します。

   アーティファクトは、Streams for Apache Kafka ソフトウェアダウンロードページ から入手できるインストールおよびサンプルファイルに含まれています。

   アーティファクトは、コンソールをインストールするためのデプロイメント YAML ファイルを提供します。

2. Operator のインストール先の namespace を定義する環境変数を設定します。

   export NAMESPACE=operator-namespace

   Copy to Clipboard Toggle word wrap

   この例では、namespace 変数は operator-namespace と定義されています。

3. OLM を使用してコンソール Operator をインストールします。

   install/console-operator/olm にあるサンプルインストールファイルを使用します。このファイルは、クラスター全体のスコープを持つ Operator をインストールするものです。これにより、Operator がすべての namespace のコンソールリソースを管理できるようになります。次のコマンドを実行して、YAML ファイルを適用し、定義された namespace に Operator をデプロイします。

   cat install/console-operator/olm/*.yaml | envsubst | kubectl apply -n ${NAMESPACE} -f -

   Copy to Clipboard Toggle word wrap

   このコマンドは、YAML ファイルを読み取り、namespace 環境変数を置き換え、結果として得られる設定を指定の OpenShift namespace に適用します。

4. デプロイメントのステータスを確認します。

   oc get pods -n operator-namespace

   Copy to Clipboard Toggle word wrap

   デプロイメント名と準備状態が表示されている出力

   NAME              READY  STATUS   RESTARTS
   console-operator  1/1    Running  1

   Copy to Clipboard Toggle word wrap

   READY は、ready/expected 状態のレプリカ数を表示します。STATUS が Running と表示されれば、デプロイメントは成功です。

5. コンソール Operator を使用して コンソールをデプロイし、Kafka クラスターに接続 します。

手順

1. コンソールのインストールアーティファクトをダウンロードして展開します。

   アーティファクトは、Streams for Apache Kafka ソフトウェアダウンロードページ から入手できるインストールおよびサンプルファイルに含まれています。

   アーティファクトには、OLM なしで Operator をインストールするためのカスタムリソース定義 (CRD) ファイル (console-operator.yaml) が含まれています。

2. Operator のインストール先の namespace を定義する環境変数を設定します。

   export NAMESPACE=operator-namespace

   Copy to Clipboard Toggle word wrap

   この例では、namespace 変数は operator-namespace と定義されています。

3. CRD を使用してコンソール Operator をインストールします。

   install/console-operator/non-olm にあるサンプルインストールファイルを使用します。このリソースは、クラスター全体のスコープを持つ Operator をインストールするものです。これにより、Operator がすべての namespace のコンソールリソースを管理できるようになります。次のコマンドを実行して YAML ファイルを適用します。

   cat install/console-operator/non-olm/console-operator.yaml | envsubst | kubectl apply -n ${NAMESPACE} -f -

   Copy to Clipboard Toggle word wrap

   このコマンドは、YAML ファイルを読み取り、namespace 環境変数を置き換え、結果として得られる設定を指定の OpenShift namespace に適用します。

4. デプロイメントのステータスを確認します。

   oc get pods -n operator-namespace

   Copy to Clipboard Toggle word wrap

   デプロイメント名と準備状態が表示されている出力

   NAME              READY  STATUS   RESTARTS
   console-operator  1/1    Running  1

   Copy to Clipboard Toggle word wrap

   READY は、ready/expected 状態のレプリカ数を表示します。STATUS が Running と表示されれば、デプロイメントは成功です。

5. コンソール Operator を使用して コンソールをデプロイし、Kafka クラスターに接続 します。