はじめに

IBM Event StreamsはWebUIからJavaを使用したサンプルコードを確認することができます。

本記事では、サンプルコードの動作に必要な設定値の確認方法(接続情報の確認方法)を記述します。

また、他にもIBM Event Streamsを使用したProducer/Consumerなどのサンプル実装はこちらのリポジトリに置いてあります。

いろんなサンプルコードが置いてあるので、これから開発を始める際や困った際はぜひ参照ください。

IBM Event Streamsへの接続情報の確認方法

サンプルコードを確認

connect to this clusterをクリック

Sample codeからサンプルコードとサンプルの設定値を確認できます
接続情報の確認

今回はJavaのApache Kafka Clientライブラリを使用している前提でSCRAM+TLSv1.2での接続方法について記述します。

より包括的な説明については、こちらの公式ドキュメントを一読ください。

https://ibm.github.io/event-automation/es/getting-started/connecting/

以下が今回の接続方式で必要な接続情報の一覧です。
```
bootstrap.servers=<kafka_bootstrap_address>
# SCRAM Properties
#security.protocol=SASL_SSL
#sasl.mechanism=SCRAM-SHA-512
#sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="<token>" password="<password>";
# TLS Properties
ssl.protocol=TLSv1.2
ssl.truststore.location=<java_truststore_file_location>
ssl.truststore.password=<java_truststore_password>
ssl.truststore.type=PKCS12
```
値が固定値のものを除くと、確認する必要がある値は以下の4つです。
- bootstrap.servers
- sasl.jaas.config
- ssl.truststore.location
- ssl.truststore.password
bootstrap.serversの確認方法

connect to this clusterをクリック

ResourcesタブのExternalタブからbootstrap.serversのアドレスを確認できます
sasl.jaas.configの確認方法

connect to this clusterをクリック

ResourcesタブのExternalタブからGenerate SCRAM credentialsをクリック

Credential名(実態としてはKafkaUserリソース名になります)とアプリケーションに許可する権限を選択

アプリケーションからアクセスを許可するトピックを選択

アプリケーションからアクセスを許可するConsumer Groupを選択

アプリケーションからアクセスを許可するTransactional IDを選択

選択した権限を持つKafkaUserのユーザ名とパスワードが表示されます

以下の設定値のにSCRAM username、<password>にSCRAM passwordを設定します
```
sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="<token>" password="<password>";
```
ssl.truststore.locationの確認方法

connect to this clusterをクリック

ResourceタブからDownload certificateをクリック

ssl.truststore.locationには、ダウンロードした証明書ファイルを配置したパスを指定します
ssl.truststore.passwordの確認方法

証明書ファイルのダウンロード後、Certificate passwordに証明書パスワードが表示されます

この値をssl.truststore.passwordに設定します