フィールドの詳細

• DEFAULT_ZK_CLIENT

  public static final java.lang.String DEFAULT_ZK_CLIENT

  関連事項:

  定数フィールド値

• DEFAULT_TOPIC

  public static final java.lang.String DEFAULT_TOPIC

  関連事項:

  定数フィールド値

• DEFAULT_OUTPUT_TYPE

  public static final java.lang.String DEFAULT_OUTPUT_TYPE

  関連事項:

  定数フィールド値

コンストラクターの詳細

• KafkaSource

  public KafkaSource(java.lang.String zkConnect)

  KafkaSource フィクスチャを初期化します。

  パラメーター:

  zkConnect - Zookeeper の接続文字列。

メソッドの詳細

• withDefaults

  public static KafkaSource withDefaults()

  デフォルトを使用して KafkaSource のインスタンスを返します。

  戻り値:

  KafkaSource のインスタンス

• toDSL

  protected java.lang.String toDSL()

  クラスからコピーされた説明: AbstractModuleFixture
  ストリーム定義に含めるのに適したモジュールの表現を返します。 例:  file --dir=xxxx --name=yyyy

  次で指定:

  クラス AbstractModuleFixture<KafkaSource> の toDSL 

• topic

  public KafkaSource topic(java.lang.String topic)

  kafka ソースのトピックを設定します

  パラメーター:

  topic - データが投稿されるトピック。

  戻り値:

  KafkaSource のインスタンス

• zkConnect

  public KafkaSource zkConnect(java.lang.String zkConnect)

  kafka ソースの zkConnect を設定する

  パラメーター:

  zkConnect - 使用する Zookeeper 接続文字列

  戻り値:

  kafka ソースのインスタンス

• outputType

  public KafkaSource outputType(java.lang.String outputType)

  kafka ソースの outputType を設定する

  パラメーター:

  outputType - 使用する出力型。

  戻り値:

  kafka ソースのインスタンス

• ensureReady

  public KafkaSource ensureReady()

  Zookeeper ソケットが最大 2 秒間ポーリングして使用可能であることを確認し、このソースに必要なトピックを作成します。

  戻り値:

  kafka ソースのインスタンス

  例外:

  java.lang.IllegalStateException - 2 秒以内に接続できない場合。