【技海登峰】Kafka漫谈系列(五)Java客户端之生产者KafkaProducer核心组件与实现原理剖析

向Kafka Broker
服务节点中发送主题消息数据的应用程序被称为生产者,生产者与消费者均属于Kafka
客户端,几乎所有主流语言都支持调用客户端API
。官方提供了基于Java
实现的kafka-clients
,用于实现生产者与消费者的基本能力;其中,生产者客户端被封装为公共类KafkaProducer
,实现简单的消息发送程序如下(不过后续开发中常用的还是spring-kafka
封装的KafkaTemplate
模板类)。
Properties props =