tKafkaCreateTopic標準プロパティ - 7.3

Kafka

EnrichVersion
Cloud
7.3
EnrichProdName
Talend Big Data
Talend Big Data Platform
Talend Data Fabric
Talend Open Studio for Big Data
Talend Real-Time Big Data Platform
EnrichPlatform
Talend Studio
task
ジョブデザインと開発 > サードパーティーシステム > メッセージングコンポーネント > Kafka
データガバナンス > サードパーティーシステム > メッセージングコンポーネント > Kafka
データクオリティとプレパレーション > サードパーティーシステム > メッセージングコンポーネント > Kafka

このプロパティはStandardジョブフレームワークで実行されているtKafkaCreateTopicを設定するために使います。

Standard 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] (トピックアクション)

トピックの作成方法を選択します。

  • [Create topic] (トピックの作成): トピックを作成します。このトピックが既に存在する場合は、ジョブ全体が停止します。

  • [Create topic if not exists] (存在しない場合はトピックを作成): このトピックが存在しない場合は、トピックを作成します。このトピックが存在する場合、ジョブは作成をスキップして次のステップに進みます。

トピック名

作成するトピックの名前を入力します。

レプリカファクター

トピックパーティションのログ(メッセージセット)に対して作成されるレプリカの数を入力します。

[Number of partitions] (パーティションの数)

トピックに対して作成するパーティションの数を入力します。

トピックの保持時間(ミリ秒)を設定する

このチェックボックスをオンにして、トピックのコンテンツが保持される最大時間をミリ秒単位で定義します。

最終的には、[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を簡単に見つけて追加できます。詳細は、外部モジュールのインストールを参照してください。