インターフェース EndpointCustomizer<T extends MethodKafkaListenerEndpoint<?,?>>

型パラメーター:
T - リスナーのエンドポイント型。
関数インターフェース:
これは関数インターフェースであるため、ラムダ式またはメソッド参照の割り当てターゲットとして使用できます。
@FunctionalInterfaceSE public interface EndpointCustomizer<T extends MethodKafkaListenerEndpoint<?,?>>
トピックの再試行機能でメイン、再試行、DLT エンドポイントをカスタマイズし、結果のトピック名を返します。
導入:
2.7.2
作成者:
Tomaz Fernandes, Wang Zhiyang
関連事項:

  • メソッドの詳細

    • customizeEndpointAndCollectTopics

      CollectionSE<EndpointCustomizer.TopicNamesHolder> customizeEndpointAndCollectTopics(T listenerEndpoint)
      エンドポイントをカスタマイズし、このエンドポイント用に生成されたトピック名を返します。
      パラメーター:
      listenerEndpoint - カスタマイズするメイン、再試行、DLT エンドポイント。
      戻り値:
      このエンドポイント用に生成されたトピック名を含むコレクション。