1.大纲
` 可以构建kafka的java客户段
了解kafka客户端类型
掌握kafka客户端的基本操作
二:客户端类型
1.五类客户端类型

2.kafka客户端API类型
AdminClient:允许管理核检测Topic,broker,以及其他的kafka对象
Producer:发布消息到topic
Consumer:订阅消息,并处理消息
Stream:高效的将输入流转换为输出流
Connectors:从一些源系统或者应用程序中拉取数据到kafka
三:AdminClient API
1.程序
四:ProducerClient API
1.发送模式
同步发送
异步发送
异步发送回调发送
2.异步发送
效果:‘
3.同步发送
4.异步回掉
效果:
5.原理分析
KafkaProducer的构造器:
sender的原理:
图形示意图:
6.自定义负载均衡器
使用:
7.消费传递保障
kafka提供了三种传递保障:
最多一次
至少一次
正好一次
传递依赖于Producer与Consumer的共同实现
传递保障主要依赖于Producer
依赖于配置项: