Kafka 将消息在磁盘上存储可配置的时间段或特定数据量。该配置也可以关闭，从而允许永久存储数据。消费者读取数据并“提交”读取位置。由于消息的持久性，事件生产者的性能不会受到消费者性能的影响。消费者也不必实时处理消息。如果消费者发生故障，重启后可以从最后的位置继续工作。除了客户端 API（生产者和消费者）之外，Kafka Connect API 和 Kafka Streams API 还提供事件流处理。通过 Connect API，Kafka 可以在数据库之间复制数据。 Kafka Streams 特别适合数据聚合和转换。数据从Kafka读取并写入Kafka。在许多情况下，流处理需要本地存储的状态 - 所谓的状态存储。随着“交互式查询”的引入，现在可以查询流的当前状态。这具有巨大的优势，因为它使实现微服务架构变得更加容易。微服务可以向 Kafka 集群发送消息，并且可以使用 Kafka 流在本地重现当前应用程序状态。对于更复杂的实时数据分析，可以使用 Apache Spark 并内置对机器学习算法的支持。
结论
借助 Kafka 消息传递平台，不仅可以实现基于事件的架构，而且最重要的是可以将数据作为全球可靠的信息源进行集中和管理。新的需求可以更快地实现，甚至可以在持续运营期间激活。
在事件溯源中，当前应用程序状态源自所有历史事件。如果实体有很 教授edu电子邮件地址 多事件，这可能会导致响应时间变慢。各种框架通常提供优化，即所谓的快照。借助 Kafka“交互式查询”，可以实时获取当前状态。
借助微服务（包括 Kafka 作为事件源），可以实现灵活且可扩展的架构。你们大多数人可能都知道区块链是加密货币“比特币”的基础。然而，区块链还解决了一个基本问题——即防止后续操纵。通过这种方式，可以轻松实现无数新的用例。您可以在我的上一篇博文中准确阅读这些内容。
但现在回到最初的问题“区块链如何工作？”：区块链是一个数据库，在其中创建新数据但不能再更改或删除。顾名思义，数据库由包含交易数据或所有权变更数据的连续区块链组成。
这些块按时间排列成一条链。为该块的全部内容创建一个哈希值，该哈希值代表该块的唯一引用。然后，下一个块引用前一个块的哈希值，并且新的块总是附加到现有链的前面。
什么是哈希？
哈希是一个数字，代表任何字符串的唯一值。有不同类型的哈希算法。哈希“SHA256”主要用于区块链技术，因为这也是比特币所需要的。
如果文本中发生了某些变化，即使只是一个字符，也会产生一个新的哈希值，任何计算机都可以快速生成该值。这样您就可以轻松检查哈希值是否与特定文本匹配。
什么是挖矿？
区块的哈希值必须满足区块链中的某些要求。例如，比特币中的哈希值必须以一定数量的零开头（难度）。