Kafka-核心API

** Kafka是一种分布式的，基于发布/订阅的消息系统，它可以让你发布和订阅记录流。在这方面，它类似于一个消息队列或企业消息系统。它可以让你持久化收到的记录流，从而具有容错能力。**

1.生产者API操作机制

生产者 API 允许应用程序发布记录流至一个或多个Kafka的话题(Topics)。
2.消费者API操作机制

消费者API 允许应用程序订阅一个或多个主题，并处理这些主题接收到的记录流。
3.Stream流式API操作机制

   Streams API 允许应用程序充当流处理器(stream processor)，从一个或多个主题获取输入流，并生产一个输出流至一个或多个的主题，能够有效地变换输入流为输出流。

4.Connector API操作机制

    Connector API 允许构建和运行可重用的生产者或消费者，能够把 Kafka主题连接到现有的应用程序或数据系统。例如，一个连接到关系数据库的连接器(connector)可能会获取每个表的变化。
    Kafka的客户端和服务器之间的通信是靠一个简单的，高性能的，与语言无关的TCP协议完成的。这个协议有不同的版本，并保持向前兼容旧版本。

    Kafka不光提供了一个Java客户端，还有许多语言版本的客户端。希望大家可以多多学习