具有非空检查的 Kafka 流应用程序

Question

我有一个流媒体应用程序，它订阅了两个主题并发布了一个主题。一个订阅的主题来自我无法控制的数据源，并给了我空值，而空值不应该是一个。

所以我正在考虑在此流式应用程序中实现 NUll-Check，但我需要知道最新发布的消息，因为目前流式应用程序是无状态的。 所以我会在流式应用程序中添加一个 statestore，我可以在其中查询最新消息。

这是一种合法的方法吗？除了向流式传输应用程序添加 "State" 之外，是否还有其他解决此主题的方法？

Answer 1

如果您想在流应用程序中处理可能的 null 值并跟踪最新发布的消息，那么是的，添加状态存储是合适的做法。