系统解读 Kafka 的流和表：弹性和容错能力

我们先从流和表的处理容错能力开始，然后再介绍弹性。我们将会看到，它们实际上是一枚硬币的两面。 容错处理 流和表具有容错能力，因为它们的数据被可靠地存储在 Kafka 中。对于流来说，这个相对好理解，因为流是直接与主题对应起来的，如果在处理过程中出了问题，重新读取主题的数据就可以了。 这对于表来说就相对复杂了，因为表必须维护额外的信息，也就是它们的状态，这样才能进行有状态的操作，比如 COUNT()

>>阅读原文<<