|
对于最新稳定版本,请使用 Spring for Apache Kafka 4.0.0! |
运行时访问主题信息
自2.9版本起,你可以通过注入提供的 在运行时访问关于主题链的信息目的地主题容器豆。
该接口提供了查找链中下一个主题的方法,或在配置后查找主题的DLT,以及诸如主题名称、延迟和类型等实用属性。
以现实场景为例,你可以利用这些信息,让控制台应用程序在处理失败的原因(如错误/不一致状态)解决后,将记录从DLT重发送到链中的第一个重试主题。
这目的地主题由DestinationTopicContainer#getNextDestinationTopicFor()方法对应输入主题链中注册的下一个主题。
消息实际转发的主题可能因异常分类、尝试次数或单主题固定延迟策略等不同因素而有所不同。
使用该目的地主题解析器如果你需要考虑这些因素,可以选择接口。 |