ストリーミングコネクタを選択します。 Kafka または HTTP

ストリームレイヤーは Kafka クラスタとして実装されます。

ストリーム レイヤーとの間で読み取りまたは書き込みを行うには、アプリケーションで次のいずれかのコネクタタイプを使用する必要があります。

  • Direct Kafka は基盤となる Kafka クラスタと直接通信するため、推奨されるコネクタタイプです。 これがデフォルトのコネクタです。
  • HTTP Connector は Kafka の上にある HTTP ラッパーであるため、通信のオーバーヘッドを意味します。

必要に応じて、プロデューサーとコンシューマーに別のコネクタータイプを指定できます。 たとえば、アプリケーションは Direct Kafka を使用してストリーム レイヤーから読み取り、 HTTP コネクタを使用して別のストリーム レイヤーに書き込みます。

データ クライアント ライブラリを使用してマーケットプレイスのデータにアクセスしているアプリケーションでは、データ使用量を計算できるように HTTP コネクタを使用する必要があります。

カフカ直轄

Direct Kafka コネクタタイプを使用するには、次の依存関係を指定する必要があります。

Maven
SBT
<dependencies>
    <dependency>
        <groupId>com.here.platform.data.client</groupId>
        <artifactId>kafka-support_2.12</artifactId>
        <version>1.18.163</version>
    </dependency>
</dependencies>
libraryDependencies += "com.here.platform.data.client" %% "kafka-support" % "1.18.163"

アプリケーションでflink-supportを使用している場合 は、依存関係がすでにflink-supportに含まれているため、この依存関係を追加する必要はありません。 詳細については、ストリームパイプラインの依存関係セクションを参照してください。

Direct Kafka サポートを有効にするには、次の設定を指定する必要があります。

here.platform.data-client.stream.connector {
  producer = "kafka-connector"
  consumer = "kafka-connector"
}

生産者と消費者は個別に設定できます。 詳細については、「設定」セクションのData Client設定ファイルを参照してください。

HTTP コネクタ

アプリケーションがマーケットプレイスのデータにアクセスする必要がある、またはプロキシの背後で実行されているなどの理由で Kafka Direct を使用できない場合は、 HTTP コネクタを使用します。

アプリケーションがプロキシの背後で実行されているなどの理由で Kafka Direct を使用できない場合は、 HTTP コネクタを使用します。 この機能を使用するには、次の設定を行う必要があります。

here.platform.data-client.stream.connector {
  producer = "http-connector"
  consumer = "http-connector"
}

生産者と消費者は個別に設定できます。 詳細については、「設定」セクションのData Client設定ファイルを参照してください。

注 : Kafka 消費者グループ名

アプリケーションが HTTP コネクタタイプを使用する場合 、コネクタは、資格情報、カタログ HERE リソースネーム 、およびレイヤー ID の特定の組み合わせについて、一意の Kafka コンシューマグループ名を定義します。 その結果、同じ資格情報を使用する 2 つのアプリケーションを実行し、同じストリーム レイヤーからのデータを消費する場合 、指定されたメッセージは 1 つのアプリケーションでのみ使用されます。 この動作を回避するには、各アプリケーションで一意の Kafka コンシューマグループを指定します。

 

」に一致する結果は 件です

    」に一致する結果はありません