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