天天看点

kafka的客户端操作,admin与producer

1.大纲

`  可以构建kafka的java客户段

  了解kafka客户端类型

  掌握kafka客户端的基本操作

二:客户端类型

1.五类客户端类型

  

kafka的客户端操作,admin与producer

2.kafka客户端API类型

  AdminClient:允许管理核检测Topic,broker,以及其他的kafka对象

  Producer:发布消息到topic

  Consumer:订阅消息,并处理消息

  Stream:高效的将输入流转换为输出流

  Connectors:从一些源系统或者应用程序中拉取数据到kafka

三:AdminClient API

1.程序

四:ProducerClient API

 1.发送模式

  同步发送

  异步发送

  异步发送回调发送

2.异步发送

  效果:‘

kafka的客户端操作,admin与producer

3.同步发送

4.异步回掉

  效果:

kafka的客户端操作,admin与producer

5.原理分析

  KafkaProducer的构造器:

  sender的原理:

  图形示意图:

kafka的客户端操作,admin与producer
kafka的客户端操作,admin与producer

6.自定义负载均衡器

  使用:

7.消费传递保障

  kafka提供了三种传递保障:

    最多一次

    至少一次

    正好一次

  传递依赖于Producer与Consumer的共同实现

  传递保障主要依赖于Producer

  依赖于配置项: