第13章 Kafka Bridge

手順

1. AMQ Streams Kafka Bridge インストールアーカイブで提供される application.properties ファイルを編集します。

   プロパティーファイルを使用して Kafka および HTTP 関連のプロパティーを指定し、分散トレーシングを有効にします。

   1. Kafka コンシューマーおよびプロデューサーに固有のプロパティーなど、標準の Kafka 関連のプロパティーを設定します。

      以下を使用します。

      • kafka.bootstrap.servers Kafka クラスターへのホスト/ポート接続を定義します。
      • kafka.producer.acks HTTP クライアントに承認を提供する

      • kafka.consumer.auto.offset.reset Kafka でオフセットのリセット方法を決定するため。

        Kafka プロパティーの設定に関する詳細は Apache Kafka の Web サイトを参照してください。

   2. HTTP 関連のプロパティーを設定し、Kafka クラスターへの HTTP アクセスを有効にします。

      以下に例を示します。

      http.enabled=true
      http.host=0.0.0.0
      http.port=8080 

      1

      
      http.cors.enabled=true 

      2

      
      http.cors.allowedOrigins=https://strimzi.io 

      3

      
      http.cors.allowedMethods=GET,POST,PUT,DELETE,OPTIONS,PATCH 

      4

      Copy to Clipboard Toggle word wrap

      1

      8080 番ポートで Kafka Bridge をリッスンするデフォルトの HTTP 設定。

      2

      CORS を有効にするには、true に設定します。

      3

      許可される CORS オリジンのコンマ区切りリスト。URL または Java 正規表現を使用できます。

      4

      CORS で許可される HTTP メソッドのコンマ区切りリスト。

   3. 分散トレーシングを有効または無効にします。

      bridge.tracing=jaeger

      Copy to Clipboard Toggle word wrap

      プロパティーからコードコメントを削除して、分散トレースを有効にします。

手順

1. AMQ Streams Kafka Bridge インストールアーカイブを任意のディレクトリーに展開していない場合は、そのディレクトリーに展開してください。

2. 設定プロパティーをパラメーターとして使用して、Kafka Bridge スクリプトを実行します。

   以下に例を示します。

   ./bin/kafka_bridge_run.sh --config-file=_path_/configfile.properties

   Copy to Clipboard Toggle word wrap

3. インストールがログで成功したことを確認します。

   HTTP-Kafka Bridge started and listening on port 8080
   HTTP-Kafka Bridge bootstrap servers localhost:9092

   Copy to Clipboard Toggle word wrap