我正在编写一个应用程序,它使用kafka producer api来发布消息。我的代码有一些键值元数据,我需要以容错的方式存储它们。我可以用Kafka的压缩主题来实现这一点。然而,Kafka StateStore 正好提供了这个功能。是否可以创建和使用 StateStore Kafka流处理器拓扑?
StateStore
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!