パッケージ org.springframework.kafka.retrytopic

インターフェース RetryTopicNamesProviderFactory.RetryTopicNamesProvider

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

  • メソッドの詳細

    • getEndpointId

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

    • getGroupId

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

    • getClientIdPrefix

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

    • getGroup

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

    • getTopicName

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