它可以让你发布和订阅记录流。在这方面,它类似于一个消息队列或企业消息系统。它可以让你持久化收到的记录流,从而具有容错能力。首先,明确几个概念:Kafka运行在一个或多个服务器上。 Kafka集群分类存储的记录流被称为主题(Topics)。 每个消息记录包含一个键,一个值和时间戳。Kafka有四个核心API:生产者API允许应用程序发布记录流至一个或多个Kafka的话题(Topics)。消费者API允许应用程序订阅一个或多个主题,并处理这些主题接收到的记录流。St