我要建立流处理系统。用Kafka传递信息。流处理可以完成风暴三叉戟，风暴或Spark流。但找不到最好的答案。
如果在开始时有条件，流处理将很简单。字段可以在不同的元组中，这就是为什么我需要存储前一个字段。现在我使用storm+redis（不是trident）实现了这个场景。在bolt内部，从redis获取所有字段，然后根据if条件进行测量。如果字段不为空则使用，如果为空则继续工作。如果这是正确的，我对建筑有不好的感觉。
我应该使用trident api还是spark streaming？
我不需要“一次交货”的保证。只需要每个数据源的状态。此状态将按字段计算。
谢谢你的回复。