tKafkaCreateTopicの標準プロパティ
これらのプロパティは、標準ジョブのフレームワークで実行されているtKafkaCreateTopicを設定するために使われます。
標準のtKafkaCreateTopicコンポーネントは、インターネットファミリーに属しています。
このフレームワーク内のコンポーネントは、ビッグデータ対応のTalend 製品すべて、およびTalend Data Fabricで利用できます。
基本設定
|
Version (バージョン) |
使うKafkaクラスターのバージョンを選択します。 |
|
[Use an existing connection] (既存の接続を使用) |
定義済みの接続の詳細を再利用する場合は、このチェックボックスをオンにして、[Component List] (コンポーネントリスト)ドロップダウンリストから、目的の接続コンポーネントを選択します。 |
|
[Zookeeper quorum list] (Zookeeperクォーラムリスト) |
使うKafkaクラスターのZookeeperサービスのアドレスを入力します。 このアドレスの形式はhostname:portです。この情報は、このKafkaクラスター内のホスティングノードの名前とポートです。 複数のアドレスを指定する必要がある場合は、コンマ(,)で区切ります。 |
|
[Action on topic] (トピックアクション) |
トピックの作成方法を選択します。
|
| トピック名 |
作成するトピックの名前を入力します。 |
|
レプリカファクター |
トピックパーティションのログ(メッセージセット)に対して作成されるレプリカの数を入力します。 |
|
[Number of partitions] (パーティションの数) |
トピックに対して作成するパーティションの数を入力します。 |
|
[Set topic retention time (ms)] (トピックの保持時間(ミリ秒)を設定) |
このチェックボックスをオンにして、トピックのコンテンツが保持される最大時間をミリ秒で定義します。 最終的には、[Advanced settings] (詳細設定)ビューの[Topic properties] (トピックのプロパティ)テーブルで定義したポリシーに応じて、コンテンツが削除または圧縮されます。 |
詳細設定
|
トピックプロパティ |
カスタマイズする必要があるKafkaトピックプロパティをこのテーブルに追加します。 このテーブルで定義できるトピックレベルプロパティの詳細は、次のWebサイトにあるKafkaのドキュメンテーションでトピックレベルの設定について説明しているセクション(http://kafka.apache.org/documentation.html#topic-config (英語のみ))をご覧ください。 |
|
[tStatCatcher Statistics] (tStatCatcher統計) |
このチェックボックスを選択すると、ジョブレベルおよび各コンポーネントレベルで処理メタデータが収集されます。 |
使用方法
|
使用ルール |
このコンポーネントは、他のKafkaコンポーネントが他のジョブまたはサブジョブで使えるトピックを作成するために、スタンドアロンで使います。 |
| 制限事項 |
ライセンスの互換性の問題のため、このコンポーネントの使用に必要な1つ以上のJARが提供されていません。この特定のコンポーネントに不足しているJARをインストールするには、Component (コンポーネント)タブビューの[Install] (インストール)ボタンをクリックします。Studioの Integration パースペクティブの[Modules] (モジュール)タブでも、不足しているすべてのJARを簡単に見つけて追加できます。詳細は、外部モジュールのインストールをご覧ください。外部モジュールをインストールする方法は、Talend Help Center (https://help.talend.com (英語のみ))をご覧ください。 |