此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring for Apache Kafka 3.3.0spring-doc.cadn.net.cn

在运行时访问主题的信息

从 2.9 开始,您可以通过在运行时通过注入提供的DestinationTopicContainer豆。 此接口提供了在链中查找下一个主题的方法,或者在 DLT 中查找主题(如果已配置),以及有用的属性,例如主题的名称、延迟和类型。spring-doc.cadn.net.cn

作为一个实际用例示例,您可以使用此类信息,以便控制台应用程序可以在处理失败的原因(例如错误/不一致状态)得到解决后,将记录从 DLT 重新发送到链中的第一个重试主题。spring-doc.cadn.net.cn

DestinationTopicDestinationTopicContainer#getNextDestinationTopicFor()method 对应于 input 主题的链中注册的下一个主题。 消息将转发到的实际主题可能会因不同的因素而有所不同,例如异常分类、尝试次数或单主题固定延迟策略。 使用DestinationTopicResolver界面,如果你需要权衡这些因素。

APP信息