|
此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 Spring for Apache Kafka 3.2.1！ |
|
此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 Spring for Apache Kafka 3.2.1！ |
从 2.9 开始，您可以通过注入提供的 Bean 在运行时访问有关主题链的信息。
此接口提供了查找链中的下一个主题或主题的 DLT（如果已配置）的方法，以及有用的属性，例如主题的名称、延迟和类型。DestinationTopicContainer
作为实际用例示例，您可以使用此类信息，以便控制台应用程序可以在解决处理失败的原因（例如错误/不一致状态）后，将记录从 DLT 重新发送到链中的第一个重试主题。
该方法提供的对应于输入主题在链中注册的下一个主题。
消息将转发到的实际主题可能因异常分类、尝试次数或单主题固定延迟策略等不同因素而有所不同。
如果您需要权衡这些因素，请使用界面。DestinationTopicDestinationTopicContainer#getNextDestinationTopicFor()DestinationTopicResolver |
该方法提供的对应于输入主题在链中注册的下一个主题。
消息将转发到的实际主题可能因异常分类、尝试次数或单主题固定延迟策略等不同因素而有所不同。
如果您需要权衡这些因素，请使用界面。DestinationTopicDestinationTopicContainer#getNextDestinationTopicFor()DestinationTopicResolver |