メインコンテンツへスキップ

はじめに

Apache Kafkaは、大量のデータを高速に処理するために構築されたストリームメッセージングプラットフォームです。 Kafkaコネクターを使用すると、メッセージングトピック、トピックデータ、パーティションに関する情報を取得して、不要なデータを排除し、最も重要なデータだけにフォーカスすることが可能になります。 Domoを使用して社内の誰もが即座にデータを利用できるようにすることで、Kafkaの確かな柔軟性を最大限に高められます。 Kafka APIの詳細については、ウェブページ( https://kafka.apache.org/documentation/ )を参照してください。 Kafkaアカウントには、Data Centerから接続します。このトピックでは、Kafkaコネクターのユーザーインターフェースに固有のフィールドとメニューについて説明します。DataSetの追加や更新スケジュールの設定、DataSet情報の編集に関する一般的な情報については、「 コネクターを使用してDataSetを追加する 」を参照してください。

必要条件

Kafkaアカウントに接続してDataSetを作成するには、以下が必要です。
  • ブートストラップサーバーのリスト
  • Kafka SASLアカウントのユーザー名とパスワード
  • SASLログインモジュール、セキュリティプロトコル、SASLメカニズム を選択する必要もあります。
また、接続先となるデータベースサーバーのポートでIPアドレスをホワイトリストに登録する必要があります。IPアドレスの詳細なリストは、「 コネクターとフェデレーテッドアダプターのIPアドレスをホワイトリストに登録する 」を参照してください。

Kafka SASLアカウントに接続する

このセクションでは、Kafka SASLコネクターページの [認証情報] および [詳細] ペインのオプションについて説明します。このページのほかのペインの項目である [スケジュール設定][DataSetの名前を付け、説明を入力] に関しては、ほとんどのタイプのコネクターで共通しています。詳細については、「 コネクターを使用してDataSetを追加する 」を参照してください。

[認証情報]ペイン

このペインには、Kafka SASLアカウントに接続する認証情報の入力フィールドが含まれています。以下の表に、各フィールドに必要な情報を示します。

フィールド

説明

Kafka BootStrap Servers

ブートストラップサーバーのリストを入力します。

Username

Kafka SASLアカウントに関連付けられたユーザー名を入力します。

Password

Kafka SASLアカウントに関連付けられたパスワードを入力します。

SASL Login Module

SASLログインモジュール選択します。

Security Protocol

セキュリティプロトコルを選択します。

SASL Mechanism

SASLメカニズムを選択します。

有効なKafka SASL認証情報を一度入力しておくと、いつでも同じアカウントを使用して新しいKafka SASL DataSetを作成できます。コネクターアカウントは、Data Centerの [アカウント] タブで管理できます。このタブの詳細については、「 コネクターのユーザーアカウントを管理する 」を参照してください。

[詳細]ペイン

このペインには、メインとなる [Reports] メニューのほか、選択したレポートタイプに応じて表示/非表示になる様々なメニューが含まれています。

メニュー

説明

Report

実行するKafka SASLレポートを選択します。以下のレポートが利用できます。

Partitions

選択したトピックに対してパーティションのリストを返します。

Topics

利用可能なトピックのリストを返します。

Topics Data

選択したトピックに対してすべてのデータを返します。

Topic Name

データを取得するトピックを選択します。

その他のペイン

スケジュール設定、再試行、オプションの更新など、コネクターインターフェースの残りのセクションについては、「 コネクターを使用してDataSetを追加する 」を参照してください。

よくある質問

レポート名 エンドポイントURL(1つまたは複数)
Partitions /topics//partitions
Topics /topics
Topics Data /consumers//instances//records
ユーザー名とパスワード(Kafka SASLアカウントに関連付けられているもの)とブートストラップサーバーのリストが必要です。SASLログインモジュール、セキュリティプロトコル、SASLメカニズムも選択する必要があります。
DataSetの更新は、15分に1回以下になるように設定してください。
制限は使用するサーバー構成によって異なります。
Kafka SASLコネクターは、作者や消費者を認証するためにシンプルな認証とセキュリティ階層(SASL)をサポートしています。Kafkaでは、SASLを使用してDomoを認証できます。