Kafkaの設定

サービスポートの種類 Kafka を使用して、Apache Kafka のトピックおよびプッシュとプルメッセージに接続します。Kafkaトピックは、1人または複数の発行者によって送信され1人または複数の消費者が読む記録(メッセージ)を保存します。1つの OSV サービスポートは、Kafkaトピックの1つのコンシューマを表します。これは、各コンシューマのためにサービスポートを作成する必要があることを意味します。

Kafka接続の認証には、SASL/PLAINメカニズムを使用します。Kafka接続は、SASL/PLAIN認証が有効の時に限り使用できます。

Kafka トピックとコンシューマーの詳細については、以下を参照してください see chapter "Kafkaメッセージを実行"

サービスポートの設定

サービスポートを作成すると、一般的なサービスポートの詳細を設定できます:

属性

説明

一般 - 名前

サービスポートの名前を入力してください。

一般 - タイプ

サービスポート技術を選択してください。

読み取り / 書き込み / 読み取り&書き込み

サービス ポートがメッセージに対して実行する処理を選択します:

  • メッセージを読み取ります。

  • メッセージを書き込みます。

  • メッセージの読み取り&;書き込みを行います。

実際のサービス

実際のサービスに接続するかどうかを選択します。

転送

OSV がリクエストを実際のサービスに転送できるようにします。このオプションを使用するには、実際のサービスを選択する必要があります。

学習

OSVレコーダータブに転送されたメッセージを保存できるようにします。このオプションを使用するには、転送を有効にする必要があります。

アクティブ

サービスポートをアクティブにするかどうかを選択。選択を解除すると非アクティブになります

Kafkaに接続するには次の属性を指定します。

属性

説明

Topic

接続先のトピック名を入力

Host

ホスト名またはIPアドレスを入力

ポート

ブローカーにアクセスするポートを指定

GroupId

このトピックの購読を登録しているコンシューマグループ名を入力

Partition

パーティションの番号を指定。例: 3

Kafkaトピックは、異なるに配置が可能な複数のパーティションに分割されます。これによって、複数のコンシューマが同時に(トピックを)読むことができます。

Peeking

Peeking 機能を有効にすると、トピックから記録を消費することなく取得できます。

これにより、位置に関係なく、オフセットに影響を与えることなく、あらゆる記録を読むことができるようになります。オフセットは記録の位置を定義します。どの記録がコンシューマによって既読になっているか、 OSV が次にどの未読記録を取得するべきかを示します。

Kafka サービスポート

変更を保存するには、適用をクリックします。変更を破棄するには、リセットをクリックします。