上下文：开票系统，发送的发票必须有连续的编号。
每张发票都有一个唯一的发票编号，为简单起见，假设它们是I1、I2、I3等。因此，系统中的第一张发票的编号为I1，并且每下一张发票都会递增。然后，每张发票都在 Kafka 主题中生成。
所以，总能只根据这个话题的内容来计算下一张发票的数量吧？（主题中的发票数量 + 1 = 下一个数字）我们可以将这样的系统称为事件源。
但是你如何做到这一点？对我来说，这似乎是一个循环数据流：为了生成主题，我首先需要确保我在另一个地方消费了相同的整个主题。
我对事件流有什么误解还是卡夫卡不可能？
发票总是被分配编号并一张一张地发送，而不是并行发送。