クラス AbstractKafkaListenerContainerFactory<C extends AbstractMessageListenerContainer<K,V>,K,V>

メソッドの詳細

• setApplicationContext

  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException

  次で指定:

  インターフェース ApplicationContextAware の setApplicationContext 

  例外:

  BeansException

• setConsumerFactory

  public void setConsumerFactory(ConsumerFactory<? super K,? super V> consumerFactory)

  使用する ConsumerFactory を指定します。

  パラメーター:

  consumerFactory - コンシューマーファクトリ。

• getConsumerFactory

  public ConsumerFactory<? super K,? super V> getConsumerFactory()

• setAutoStartup

  public void setAutoStartup(BooleanSE autoStartup)

  autoStartup boolean フラグを指定します。

  パラメーター:

  autoStartup - 自動起動の場合は true。

  関連事項:

  • AbstractMessageListenerContainer.setAutoStartup(boolean)

• setPhase

  public void setPhase(int phase)

  使用する phase を指定します。

  パラメーター:

  phase - フェーズ。

  関連事項:

  • AbstractMessageListenerContainer.setPhase(int)

• setRecordMessageConverter

  public void setRecordMessageConverter(RecordMessageConverter recordMessageConverter)

  レコードリスナーに動的な引数の型の一致が必要な場合に使用するメッセージコンバーターを設定します。

  パラメーター:

  recordMessageConverter - コンバーター。

  導入:

  2.9.6

• setBatchMessageConverter

  public void setBatchMessageConverter(BatchMessageConverter batchMessageConverter)

  バッチリスナーに動的な引数の型の一致が必要な場合に使用するメッセージコンバーターを設定します。

  パラメーター:

  batchMessageConverter - コンバーター。

  導入:

  2.9.6

• setRecordFilterStrategy

  public void setRecordFilterStrategy(RecordFilterStrategy<? super K,? super V> recordFilterStrategy)

  レコードフィルター戦略を設定します。

  パラメーター:

  recordFilterStrategy - 戦略。

• setAckDiscarded

  public void setAckDiscarded(BooleanSE ackDiscarded)

  フィルター戦略が使用されているときに破棄を確認するには、true に設定します。

  パラメーター:

  ackDiscarded - ackDiscarded。

• isBatchListener

  public BooleanSE isBatchListener()

  このエンドポイントがバッチリスナーを作成する場合は true を返します。

  戻り値:

  バッチリスナーの場合は true。

  導入:

  1.1

• setBatchListener

  public void setBatchListener(BooleanSE batchListener)

  このエンドポイントがバッチリスナーを作成する必要がある場合は、true に設定します。

  パラメーター:

  batchListener - バッチリスナーの場合は true。

  導入:

  1.1

• setApplicationEventPublisher

  public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)

  次で指定:

  インターフェース ApplicationEventPublisherAware の setApplicationEventPublisher 

• setReplyTemplate

  public void setReplyTemplate(KafkaTemplate<?,?> replyTemplate)

  返信の送信に使用する KafkaTemplate を設定します。

  パラメーター:

  replyTemplate - テンプレート。

  導入:

  2.0

• setCommonErrorHandler

  public void setCommonErrorHandler(CommonErrorHandler commonErrorHandler)

  レコードリスナーとバッチリスナーの両方のエラーを処理できる CommonErrorHandler を設定します。

  パラメーター:

  commonErrorHandler - ハンドラー。

  導入:

  2.8

• setAfterRollbackProcessor

  public void setAfterRollbackProcessor(AfterRollbackProcessor<? super K,? super V> afterRollbackProcessor)

  トランザクションのロールバック後に呼び出すようにプロセッサーを設定します。通常、未処理のトピック / パーティションを探してレコードを再処理します。デフォルトでは、失敗したレコードを含めてそうします。

  パラメーター:

  afterRollbackProcessor - プロセッサー。

  導入:

  1.3.5

• setReplyHeadersConfigurer

  public void setReplyHeadersConfigurer(ReplyHeadersConfigurer replyHeadersConfigurer)

  応答メッセージを作成するときに呼び出される設定者を設定します。

  パラメーター:

  replyHeadersConfigurer - コンフィギュレーター。

  導入:

  2.2

• setMissingTopicsFatal

  public void setMissingTopicsFatal(boolean missingTopicsFatal)

  false に設定すると、構成されたトピックのいずれかがブローカーに存在しない場合でもコンテナーを開始できます。トピックパターンが構成されている場合は適用されません。デフォルトは true。

  パラメーター:

  missingTopicsFatal - 欠落している TopicsFatal。

  導入:

  2.3

• getContainerProperties

  public ContainerProperties getContainerProperties()

  このファクトリのプロパティテンプレートを取得します。必要に応じてプロパティを設定すると、エンドポイントの最終的なプロパティインスタンスにコピーされます。

  戻り値:

  プロパティ。

• setRecordInterceptor

  public void setRecordInterceptor(RecordInterceptor<K,V> recordInterceptor)

  リスナーを呼び出す前に呼び出されるインターセプターを設定します。レコードリスナーでのみ使用されます。

  パラメーター:

  recordInterceptor - インターセプター。

  導入:

  2.2.7

  関連事項:

  • setBatchInterceptor(BatchInterceptor)

• setBatchInterceptor

  public void setBatchInterceptor(BatchInterceptor<K,V> batchInterceptor)

  リスナーの呼び出しの前後に呼び出されるバッチインターセプターを設定します。バッチリスナーでのみ使用されます。

  パラメーター:

  batchInterceptor - インターセプター。

  導入:

  2.7

  関連事項:

  • setRecordInterceptor(RecordInterceptor)

• setBatchToRecordAdapter

  public void setBatchToRecordAdapter(BatchToRecordAdapter<K,V> batchToRecordAdapter)

  BatchToRecordAdapter を設定します。

  パラメーター:

  batchToRecordAdapter - アダプター。

  導入:

  2.4.2

• setContainerCustomizer

  public void setContainerCustomizer(ContainerCustomizer<K,V,C> containerCustomizer)

  コンテナーの作成後にコンテナーをさらに構成するために使用されるカスタマイザーを設定します。

  パラメーター:

  containerCustomizer - カスタマイザー。

  導入:

  2.3.4

• setCorrelationHeaderName

  public void setCorrelationHeaderName(StringSE correlationHeaderName)

  相関 ID のカスタムヘッダー名を設定します。デフォルト KafkaHeaders.CORRELATION_ID。このヘッダーは、返信メッセージでエコーバックされます。

  パラメーター:

  correlationHeaderName - ヘッダー名。

  導入:

  3.0

• setChangeConsumerThreadName

  public void setChangeConsumerThreadName(boolean changeConsumerThreadName)

  初期化中にコンシューマースレッド名を変更するようコンテナーに指示するには、true に設定します。

  パラメーター:

  changeConsumerThreadName - 変更するのは本当です。

  導入:

  3.0.1

  関連事項:

  • setThreadNameSupplier(Function)

• setThreadNameSupplier

  public void setThreadNameSupplier(FunctionSE<MessageListenerContainer,StringSE> threadNameSupplier)

  コンシューマースレッド名を変更するために使用する関数を設定します。デフォルトではコンテナー listenerId が返されます。

  パラメーター:

  threadNameSupplier - 関数。

  導入:

  3.0.1

  関連事項:

  • setChangeConsumerThreadName(boolean)

• createListenerContainer

  public C createListenerContainer(KafkaListenerEndpoint endpoint)

  インターフェースからコピーされた説明: KafkaListenerContainerFactory

  指定された KafkaListenerEndpoint の MessageListenerContainer を作成します。このメソッドを使用して作成されたコンテナーは、リスナーエンドポイントレジストリに追加されます。

  次で指定:

  インターフェース KafkaListenerContainerFactory<C extends AbstractMessageListenerContainer<K,V>> の createListenerContainer 

  パラメーター:

  endpoint - 構成するエンドポイント

  戻り値:

  作成されたコンテナー

• createContainerInstance

  protected abstract C createContainerInstance(KafkaListenerEndpoint endpoint)

  空のコンテナーインスタンスを作成します。

  パラメーター:

  endpoint - エンドポイント。

  戻り値:

  新しいコンテナーインスタンス。

• initializeContainer

  protected void initializeContainer(C instance, KafkaListenerEndpoint endpoint)

  さらに、指定されたコンテナーを初期化します。

  サブクラスはこのメソッドを継承して、必要に応じて追加の構成を適用できます。

  パラメーター:

  instance - 構成するコンテナーインスタンス。

  endpoint - エンドポイント。

• createContainer

  public C createContainer(TopicPartitionOffset... topicsAndPartitions)

  インターフェースからコピーされた説明: KafkaListenerContainerFactory

  リスナーなしでコンテナーを作成および構成します。KafkaListener アノテーションに使用されないコンテナーを作成するために使用されます。この方法を使用して作成されたコンテナーは、リスナーエンドポイントレジストリに追加されません。

  次で指定:

  インターフェース KafkaListenerContainerFactory<C extends AbstractMessageListenerContainer<K,V>> の createContainer 

  パラメーター:

  topicsAndPartitions - 割り当てる topicPartitions。

  戻り値:

  コンテナー。

• createContainer

  public C createContainer(StringSE... topics)

  インターフェースからコピーされた説明: KafkaListenerContainerFactory

  リスナーなしでコンテナーを作成および構成します。KafkaListener アノテーションに使用されないコンテナーを作成するために使用されます。この方法を使用して作成されたコンテナーは、リスナーエンドポイントレジストリに追加されません。

  次で指定:

  インターフェース KafkaListenerContainerFactory<C extends AbstractMessageListenerContainer<K,V>> の createContainer 

  パラメーター:

  topics - トピック。

  戻り値:

  コンテナー。

• createContainer

  public C createContainer(PatternSE topicPattern)

  インターフェースからコピーされた説明: KafkaListenerContainerFactory

  リスナーなしでコンテナーを作成および構成します。KafkaListener アノテーションに使用されないコンテナーを作成するために使用されます。この方法を使用して作成されたコンテナーは、リスナーエンドポイントレジストリに追加されません。

  次で指定:

  インターフェース KafkaListenerContainerFactory<C extends AbstractMessageListenerContainer<K,V>> の createContainer 

  パラメーター:

  topicPattern - topicPattern。

  戻り値:

  コンテナー。

• createContainer

  protected C createContainer(KafkaListenerEndpoint endpoint)

• customizeContainer

  protected void customizeContainer(C instance, KafkaListenerEndpoint endpoint)