卡夫卡:如何查询主题的前一状态

Question

我对卡夫卡非常陌生，我想知道什么是最好的可能性来质疑一个话题的先前/历史状态。

示例

• 假设我有一本主题书，其中包含了我书架上每一类书的图书数量。
• 作为关键，我使用书籍的类别(例如“科学”、“幻想”、“外国”)。

现在发生下列事件：

晚上9点。我的书架上有10本科学书籍和15本幻想书：

"science":10, "fantasy":15, "foreign": 2

晚上10点。我拿了3本书：

"science":9, "fantasy":13 (unchanged: "foreign": 2)

晚上11点。我加了5本书：

"science":13, "fantasy":14  (unchanged: "foreign": 2)

问题与预期产出

卡夫卡在给定时间询问我书架上的书籍数量的最佳方法是什么？例如，如果我在晚上10:15查询这个号码。预期的答案是

"science":9, "fantasy":13, "foreign": 2

Answer 1

你不能“夺走”卡夫卡。卡夫卡不是排队，而是一根木头。消费并没有打破记录，它只是基于民意调查的阅读。

当您为一个kafka主题生成一个记录时，该记录将一直保存在这个主题/分区中，直到它过期(或发生任何删除策略)。

因此，看起来卡夫卡可能不是满足您需要的最佳技术(可能使用一些队列技术，比如rabbitMQ)，但也许您可以开发一些您想要实现的东西(使用有状态的KStreams可以完成任务)。

扬尼克