インターフェース RetryTopicNamesProviderFactory.RetryTopicNamesProvider

すべての既知の実装クラス:
SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider
含まれているインターフェース:
RetryTopicNamesProviderFactory
public static interface RetryTopicNamesProviderFactory.RetryTopicNamesProvider
作成者:
Andrea Polci

  • メソッドの詳細

    • getEndpointId

      @Nullable StringSE getEndpointId(KafkaListenerEndpoint endpoint)
      エンドポイントの現在の ID を上書きするエンドポイント ID を返します。
      パラメーター:
      endpoint - オーバーライドするエンドポイント
      戻り値:
      エンドポイント ID

    • getGroupId

      @Nullable StringSE getGroupId(KafkaListenerEndpoint endpoint)
      エンドポイントの groupId をオーバーライドする groupId を返します。
      パラメーター:
      endpoint - オーバーライドするエンドポイント
      戻り値:
      groupId

    • getClientIdPrefix

      @Nullable StringSE getClientIdPrefix(KafkaListenerEndpoint endpoint)
      エンドポイントの clientId プレフィックスをオーバーライドする clientId プレフィックスを返します。
      パラメーター:
      endpoint - オーバーライドするエンドポイント
      戻り値:
      clientId プレフィックス

    • getGroup

      @Nullable StringSE getGroup(KafkaListenerEndpoint endpoint)
      エンドポイントのグループをオーバーライドするグループを返します。
      パラメーター:
      endpoint - オーバーライドするエンドポイント
      戻り値:
      clientId プレフィックス

    • getTopicName

      @Nullable StringSE getTopicName(StringSE topic)
      ベーストピック名を上書きする熱帯の名前を返します。
      パラメーター:
      topic - ベーストピック名
      戻り値:
      トピック名