小编Ham*_*mid的帖子

下面是我的要求，举一个简单的例子：

public interface Animal {}

@Component
@Order(1)
public class Hippo implements Animal{}

@Component
@Order(2)
public class Crocodile implements Animal{}

我想以List不同的顺序将它们注入两个。例如landAnimals，第一个索引中应该有河马，第二个索引中waterAnimals应该有鳄鱼，而第一个索引中应该有鳄鱼，第二个索引中应该有河马。

@Autowired
private List<Animal> landAnimals; // 0-Hippo & 1-Crocodile (achieved with @Order)

@Autowired
private List<Animal> waterAnimals; // 0-Crocodile & 1-Hippo (not achieved)

@Order，我们可以动态更改它吗？

我需要延迟处理某些事件。

例如。我有三个事件（发布在 Kafka 上）：

• A（id：1，重试时间：现在）
• B（id：2，重试时间：10分钟后）
• C（id：3，重试时间：现在）

我需要立即处理记录A和C，而记录B需要十分钟后处理。在 Apache Flink 中这是否可行？

到目前为止，无论我研究过什么，“触发器”似乎可能有助于在 Flink 中实现它，但尚未能够正确实现它。

我也查看了 Kafka 文档，但看起来不太可行。