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



我得到了一个流媒体应用程序,它订阅了两个主题并发布了一个主题。一个订阅的Topic来自我无法控制的数据源,并为我提供了null值,其中不应该是。

所以我想在这个流媒体应用程序中实现NUll Check,但我需要知道最新发布的消息,因为目前流媒体应用有点无状态。所以我会在流媒体应用程序中添加一个状态存储,在那里我可以查询最新消息。

这是合法的做法吗?除了在流媒体应用程序中添加"状态"之外,还有其他方法可以解决这个问题吗?

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

相关内容

  • 没有找到相关文章

最新更新