文件名称:kafka架构与原理
文件大小:475KB
文件格式:PDF
更新时间:2024-03-16 04:18:43
kafka架构与原理
它可以让你发布和订阅记录流。在这方面,它类似于一个消息队列或企业消息系统。它可以让你持久化收到的记录流,从而具有容错能力。首先,明确几个概念:Kafka运行在一个或多个服务器上。Kafka集群分类存储的记录流被称为主题(Topics)。每个消息记录包含一个键,一个值和时间戳。Kafka有四个核心API:生产者API允许应用程序发布记录流至一个或多个Kafka的话题(Topics)。消费者API允许应用程序订阅一个或多个主题,并处理这些主题接收到的记录流。StreamsAPI允许应用程序充当流处理器(streamprocessor),从一个或多个主题获取输入流,并生产一个输出流至一个或多个的主题