Kafka作为数据库缓存

我有5个kafka主题,每秒将有100 msgs消息流。消息格式如下

{null,JSON}(分区:10)

我需要根据JSON中的值从过去提取一条记录,并在我的Java应用程序中进行处理。正确的方法是什么?

  1. ksqlDB流
  2. 卡夫卡流
  3. Ktable

提前致谢。