第14章 Kafka への接続

手順

1. クラスター管理者権限を持つアカウントで OpenShift にログインします。以下に例を示します。

   $ oc login -u admin -p admin

   Copy to Clipboard Toggle word wrap

2. 現在のプロジェクトが Fuse Online で稼働しているプロジェクトであることを確認します。現在のプロジェクトを表示するには、以下のコマンドを実行します。

   $ oc project

   Copy to Clipboard Toggle word wrap

3. クラスターの Kafka ブローカーが oc ユーザーアカウントにアクセスできるようにするための権限を付与します。クラスターの設定方法によって、付与する必要のある権限が決まります。たとえば、minishift 上の Strimzi クラスターの場合、以下を行うことができます。

   1. クラスターの Kafka/Strimzi リソースにアクセスできるクラスターロールを作成します。以下の例では、kafkas.kafka.strimzi.io-view が新規ロールの名前になります。

      oc create clusterrole kafkas.kafka.strimzi.io-view --verb=get,list --resource=kafkas --resource=crd

      Copy to Clipboard Toggle word wrap

   2. このクラスターロールを oc ユーザーに追加します。以下の例では、syndesis-server が oc ユーザーアカウントの名前になります。

      oc adm policy add-cluster-role-to-user kafkas.kafka.strimzi.io-view -z syndesis-server

      Copy to Clipboard Toggle word wrap