我读了，但我不能理解太多。我读到我可以使用 KTable 而不是日志压缩。或者它有更多的功能。但是，我找不到这方面的好例子。我也无法在解释工作逻辑的好来源中看到它。你能解释一个 ktable 和 kstream 的好例子吗？我能做什么？
最佳答案
根据我的理解，我们应该使用 KStream 作为我们想要从源接收的数据，并且可以接受数据重复。
当我们不想保留记录的重复并且我们只对相应键的最新值感兴趣时，我们应该使用KTable。
Kstream 是连续的。
关于apache-kafka - 为什么要使用 KStream 或 KTable？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/60467888/