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 サービスポート
変更を保存するには、適用をクリックします。変更を破棄するには、リセットをクリックします。