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