Kafka 架构

Kafka基本架构 生产者API 允许应用程序发布记录流至一个或者多个kafka的主题（topics）。 消费者API 允许应用程序订阅一个或者多个主题，并处理这些主题接收到的记录流。 StreamsAPI 允许应用程序充当流处理器（stream processor），从一个或者多个主题获取输入流，并生产一个输出流到一个或 者多个主题，能够有效的变化输入流为输出流。 ConnectAPI 允许构建

>>阅读原文<<