第3章 Service Registry のインストール

手順

1. AMQ Streams がインストールされていない場合は、OpenShift クラスターに AMQ Streams をインストールします。たとえば、AMQ Streams のダウンロードディレクトリーから以下のコマンドを入力します。

   oc apply -f install/cluster-operator/

2. Kafka クラスターがまだ設定されていない場合は、AMQ Streams で新しい Kafka クラスターを作成します。以下に例を示します。

   $ cat << EOF | oc create -f -
   apiVersion: kafka.strimzi.io/v1beta1
   kind: Kafka
   metadata:
    name: my-cluster
   spec:
    kafka:
      replicas: 3
      listeners:
        external:
          type: route
      storage:
        type: ephemeral
    zookeeper:
      replicas: 3
      storage:
        type: ephemeral
    entityOperator:
      topicOperator: {}
   EOF

   この簡単な例では、一時ストレージを使用して、3 つの Zookeeper ノードと 1 つの Kafka ノードを持つクラスターを作成します。すべてのデータは、Pod が OpenShift で実行されなくなった時点で失われます。

3. AMQ Streams に Service Registry アーティファクトを保存するために必要な storage-topic を作成します。以下に例を示します。

   $ cat << EOF | oc create -f -
   apiVersion: kafka.strimzi.io/v1beta1
   kind: KafkaTopic
   metadata:
     name: storage-topic
     labels:
       strimzi.io/cluster: my-cluster
   spec:
     partitions: 3
     replicas: 3
     config:
       cleanup.policy: compact
   EOF

4. AMQ Streams に Service Registry グローバル ID を保存するために必要な global-id-topic を作成します。以下に例を示します。

   $ cat << EOF | oc create -f -
   apiVersion: kafka.strimzi.io/v1beta1
   kind: KafkaTopic
   metadata:
     name: global-id-topic
     labels:
       strimzi.io/cluster: my-cluster
   spec:
     partitions: 3
     replicas: 3
     config:
       cleanup.policy: compact
   EOF