衡阳网站页面设计公司,溧阳市住房和城乡建设局网站,网站访客qq获取系统 报价,贵州省住房和城乡建设厅网站打不开目录 Kafka核心API 及 生产者API讲解★ Kafka的核心APIKafka包含如下5类核心API#xff1a; ★ 生产者APIKafka 的API 文档 ★ 使用生产者API发送消息 Kafka核心API 及 生产者API讲解
官方文档
★ Kafka的核心API
Kafka包含如下5类核心API#xff1a; Producer API#x… 目录 Kafka核心API 及 生产者API讲解★ Kafka的核心APIKafka包含如下5类核心API ★ 生产者APIKafka 的API 文档 ★ 使用生产者API发送消息 Kafka核心API 及 生产者API讲解
官方文档
★ Kafka的核心API
Kafka包含如下5类核心API Producer API生产者API 应用程序通过该API向主题发布消息。
Consumer API消费者API 应用程序通过该API订阅一个或多个主题并从所订阅的主题中拉取消息记录
Streams API流API 应用程序可通过该API实现流处理器可以将一个主题的消息“导流”到另一个主题并能地对消息进行任意自定义的转换。
类似于 RabbitMQ 的 Exchange
Connector API连接器API 应用程序可通过这套API来实现连接器这些连接器不断地从源系统或应用程序导入数据到Kafka反过来也可将Kafka消息不断地导入某个接收系统或应用程序。
通过这个API可以让应用程序和Kafka这个消息系统进行一个实时的交互我们的系统可以不断的接收来自Kafka的消息也可以让我们的程序不断的把数据导入到Kafka的消息系统中就像是一个通道所以叫连接API。
应用场景我们的应用程序要和Kafka之间保持实时的数据流的时候就可以用这个连接API。
AdminAPI管理API 应用程序可通过该API管理和检查主题、Broker和其他Kafka实体。 这5套API中只有流API使用的是专门的JAR包。
其他都用的是org.apache.kafka:kafka-clients依赖库。
而流API用的是org.apache.kafka:kafka-streams依赖库。 ★ 生产者API dependencygroupIdorg.apache.kafka/groupIdartifactIdkafka-clients/artifactIdversion3.6.1/version
/dependency生产者API 的核心类是 KafkaProducer它提供了一个 send()方法 来发送消息该方法需要传入一个 ProducerRecordK,V对象。
ProducerRecord 代表了一条消息Kafka 的消息是包含了key、value、timestamp。
ProducerRecord定义了如下6个构造器
- ProducerRecord(String topic, Integer partition, K key, V value)创建一条发送到指定主题和指定分区的消息。- ProducerRecord(String topic, Integer partition, K key, V value, IterableHeader headers)创建一条发送到指定主题和指定分区的消息且包含多个消息头。- ProducerRecord(String topic, Integer partition, Long timestamp, K key, V value)创建一条发送到指定主题和指定分区的消息且使用给定的时间戳。- ProducerRecord(String topic, Integer partition, Long timestamp, K key, V value, IterableHeader headers)创建一条发送到指定主题和指定分区的消息、使用给定的时间戳且包含多个消息头。- ProducerRecord(String topic, K key, V value)创建一条发送到指定主题的消息。- ProducerRecord(String topic, V value)创建一条发送到指定主题的、只带value不带key的消息。通过查 API 文档可看这个 ProducerRecord 消息对象 的6个构造器 Kafka 的API 文档
Kafka 的API 文档 ★ 使用生产者API发送消息
使用生产者API发送消息很简单基本只要两步
1、创建KafkaProducer对象创建该对象时要传入Properties对象用于对该生产者进行配置。
2、调用KafkaProducer对象的send()方法发送消息调用ProducerRecord的构造器即可创建不同的消息。
3、发送完成后关闭KafkaProducer对象。 为何Kafka的KafkaProducer需要一个Properties来来创建KafkaProducer
因为Kafka的Producer API提供了海量的配置选项——如果你将这些配置选项每个都定义成方法那将是一件让人无比痛苦的事情。
所以Kafka在设计该API时就直接用了一个Properties来封装所有的配置属性。
