はじめに
Apache Kafkaは、大量のデータを高速に処理するために構築されたストリームメッセージングプラットフォームです。DomoのApache Kafka RESTプロキシコネクターを使用すると、ブローカー、パーティション、トピック、トピックメタデータ、トピックレコードに関する情報を取得できるため、不要な情報を排除して最も重要な通信に集中できます。Kafka REST APIについて詳しくは、ウェブサイト（ https://docs.confluent.io/current/ka…ocs/intro.html ）を参照してください。 KafkaサーバーにはData Centerから接続してアカウントを設定します。このトピックでは、Kafka RESTコネクターのユーザーインターフェース別のフィールドとメニューについて説明します。DataSetの追加や更新スケジュールの設定、DataSet情報の編集に関する一般的な情報は、「 コネクターを使用してDataSetを追加する 」を参照してください。必要条件
Kafka RESTアカウントに接続してDataSetを作成するには、Kafkaサーバーの名前が必要です。接続先となるデータベースサーバーのポートで以下のIPアドレスをホワイトリストに登録する必要があります。IPアドレスの詳細なリストは、「 コネクターとフェデレーテッドアダプターのIPアドレスをホワイトリストに登録する 」を参照してください。Kafka RESTサーバーに接続する
このセクションでは、Kafka RESTコネクターページの ［認証情報］ および ［詳細］ ペインのオプションについて説明します。このページのほかのペインの項目にある ［スケジュール設定］ や ［DataSetに名前を付け、説明を入力］ に関しては、ほとんどのタイプのコネクターで共通しています。詳細については、「 コネクターを使用してDataSetを追加する 」を参照してください。［認証情報］ペイン
このペインには、Kafka RESTアカウントに接続する認証情報の入力フィールドがあります。下表では、各フィールドに必要な内容を説明しています。フィールド | 説明 |
|---|---|
Kafka Server | Kafkaサーバーのホスト/ポートのペアのリストを入力します。 |
［詳細］ペイン
このペインには、メインとなる ［Reports］ メニューのほか、選択したレポートタイプに応じて表示/非表示になる様々なメニューが含まれています。メニュー | 説明 | ||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|
Report | 実行するKafka RESTレポートを選択します。以下のレポートが利用できます。
| ||||||||||
Topic Name | データを取得するトピックを選択します。 | ||||||||||
Group Name | データを取得するコンシューマーグループの名前を入力します。 | ||||||||||
Name（オプション） | データを取得するコンシューマーインスタンスの名前を入力します。 | ||||||||||
Auto Offset Reset（オプション） | コンシューマーにauto.offset.resetの値を入力します。 | ||||||||||
Auto Commit Enable（オプション） | コンシューマーにauto.commit.enableの値を入力します。 | ||||||||||
Timeout（オプション） | レコードを取得するための基盤となるクライアントライブラリのポーリング（タイムアウト）リクエストのミリ秒数を入力します。 | ||||||||||
Max Bytes（オプション） | 応答に含めるエンコードされていないキーと値の最大バイト数を入力します。 |