企业🤖AI智能体构建引擎,智能编排和调试,一键部署,支持私有化部署方案 广告
Kafak 常用 API 包括: * Producer API(Kafka Java Clients):允许应用程序将记录流发布到一个或多个 Kafka 主题。 * Consumer API(Kafka Java Clients):允许应用程序订阅一个或多个主题。 * Streams API(Kafka Streams 组件):允许应用程序充当流处理器,使用一个或多个主题的输入流,生成一个或多个输出主题的输出流,有效地将输入流转换为输出流。 * Connector API(Kafka Connect 组件):允许构建和运行可重用的生产者或消费者,将 Kafka 主题连接到现有的应用程序或数据系统。 ![](https://img.kancloud.cn/84/ad/84add430f5aa1248d40bce867d9cfb46_783x441.png) maven依赖,*`pom.xml`*: ```xml <!--kafka--> <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>0.11.0.2</version> </dependency> ```