《kafka权威指南》学习记录1

本博客只作为自己学习的一个记录。
一.kafka生产者
1.kafka生产者组件
main线程 send线程 producerrecord对象 序列化器 分区器。
Producerrecord对象格式:topic [key] [partition] value
2.生产者发送消息过程
3.kafka生产者应用程序开发步骤
创建生产者
Properties KafkaProducer 三个必须配置：kafka ip,key和value的序列化方式。
发送消息到kafka
发送并忘记
同步发送：feature对象的get方法
异步发送：send()方法里传入一个回调函数
其他的一些配置 能说出几个
顺序保证：retries设为0 max.in.flight.requests.per.connection topic分区数为1
4.序列化器
自定义序列化器
实现serializer接口，重写configure() serialize() close()方法，不建议自定义，kafka自带已够用。
arvo序列化方式

《kafka权威指南》学习记录1最先出现在Python成神之路。