クラス KafkaListenerEndpointRegistrar

メソッドの詳細

• setEndpointRegistry

  public void setEndpointRegistry(KafkaListenerEndpointRegistry endpointRegistry)

  使用する KafkaListenerEndpointRegistry インスタンスを設定します。

  パラメーター:

  endpointRegistry - 使用する KafkaListenerEndpointRegistry インスタンス。

• getEndpointRegistry

  @Nullable public KafkaListenerEndpointRegistry getEndpointRegistry()

  このレジストラの KafkaListenerEndpointRegistry インスタンスを返します。null の場合があります。

  戻り値:

  このレジストラの KafkaListenerEndpointRegistry インスタンスは null である可能性があります。

• getCustomMethodArgumentResolvers

  public ListSE<HandlerMethodArgumentResolver> getCustomMethodArgumentResolvers()

  HandlerMethodArgumentResolver のリストを返します。

  戻り値:

  HandlerMethodArgumentResolver のリスト。

  導入:

  2.4.2

• setCustomMethodArgumentResolvers

  public void setCustomMethodArgumentResolvers(HandlerMethodArgumentResolver... methodArgumentResolvers)

  カスタムメソッド引数リゾルバーを KafkaListenerAnnotationBeanPostProcessor デフォルトの空のリストに追加します。

  パラメーター:

  methodArgumentResolvers - 割り当てる methodArgumentResolvers。

  導入:

  2.4.2

• setMessageHandlerMethodFactory

  public void setMessageHandlerMethodFactory(MessageHandlerMethodFactory kafkaHandlerMethodFactory)

  MessageHandlerMethodFactory を使用して、このプロセッサーによって検出されたエンドポイントを処理するメッセージリスナーを構成するように設定します。

  デフォルトでは DefaultMessageHandlerMethodFactory が使用され、追加のメソッド引数をサポートするように、または変換と検証のサポートをカスタマイズするようにさらに構成できます。詳細については、DefaultMessageHandlerMethodFactory javadoc を参照してください。

  パラメーター:

  kafkaHandlerMethodFactory - MessageHandlerMethodFactory インスタンス。

• getMessageHandlerMethodFactory

  @Nullable public MessageHandlerMethodFactory getMessageHandlerMethodFactory()

  使用するカスタム MessageHandlerMethodFactory があれば、それを返します。

  戻り値:

  使用するカスタム MessageHandlerMethodFactory がある場合。

• setContainerFactory

  public void setContainerFactory(KafkaListenerContainerFactory<?> containerFactory)

  KafkaListenerEndpoint が null コンテナーファクトリに登録されている場合に使用する KafkaListenerContainerFactory を設定します。

  または、使用する KafkaListenerContainerFactory の Bean 名を遅延ルックアップに指定できます。setContainerFactoryBeanName(java.lang.String) を参照してください。

  パラメーター:

  containerFactory - KafkaListenerContainerFactory インスタンス。

• setContainerFactoryBeanName

  public void setContainerFactoryBeanName(StringSE containerFactoryBeanName)

  KafkaListenerEndpoint が null コンテナーファクトリに登録されている場合に使用する KafkaListenerContainerFactory の Bean 名を設定します。または、コンテナーファクトリインスタンスを直接登録することもできます。setContainerFactory(KafkaListenerContainerFactory) を参照してください。

  パラメーター:

  containerFactoryBeanName - KafkaListenerContainerFactory Bean 名。

  関連事項:

  • setBeanFactory(org.springframework.beans.factory.BeanFactory)

• setBeanFactory

  public void setBeanFactory(BeanFactory beanFactory)

  BeanFactory は、setContainerFactoryBeanName(java.lang.String) と組み合わせて使用する必要があるだけです。

  次で指定:

  インターフェース BeanFactoryAware の setBeanFactory 

  パラメーター:

  beanFactory - BeanFactory インスタンス。

• getValidator

  @Nullable public Validator getValidator()

  提供されている場合、バリデーターを取得します。

  戻り値:

  バリデーター。

  導入:

  2.2

• setValidator

  public void setValidator(Validator validator)

  デフォルトのメッセージハンドラーファクトリを使用する場合に使用するバリデーターを設定します。

  パラメーター:

  validator - バリデーター。

  導入:

  2.2

• afterPropertiesSet

  public void afterPropertiesSet()

  次で指定:

  インターフェース InitializingBean の afterPropertiesSet 

• registerAllEndpoints

  protected void registerAllEndpoints()

• registerEndpoint

  public void registerEndpoint(KafkaListenerEndpoint endpoint, @Nullable KafkaListenerContainerFactory<?> factory)

  基になるコンテナーの作成に使用する KafkaListenerContainerFactory と一緒に新しい KafkaListenerEndpoint を登録します。

  そのエンドポイントにデフォルトのファクトリを使用する必要がある場合、factory は null になります。

  パラメーター:

  endpoint - 登録する KafkaListenerEndpoint インスタンス。

  factory - 使用する KafkaListenerContainerFactory。

• registerEndpoint

  public void registerEndpoint(KafkaListenerEndpoint endpoint)

  デフォルトの KafkaListenerContainerFactory を使用して新しい KafkaListenerEndpoint を登録し、基になるコンテナーを作成します。

  パラメーター:

  endpoint - 登録する KafkaListenerEndpoint インスタンス。

  関連事項:

  • setContainerFactory(KafkaListenerContainerFactory)
  • registerEndpoint(KafkaListenerEndpoint, KafkaListenerContainerFactory)