带回调函数的生产者 | 学习笔记

简介: 快速学习带回调函数的生产者

开发者学堂课程【分布式消息系统 Kafka 快速入门:带回调函数的生产者】学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址https://developer.aliyun.com/learning/course/98/detail/1611


带回调函数的生产者


一、 发送数据


发送方法有两个,其中 callback 是一个接口,接口可以被直接使用,将它的实现方法写出即可。

每次发送一条数据之后都会回到以下方法。

111.png

其中 recordmetadata 是源数据信息

需要将其打印就需要判断 exception 是否等于 null,如果不等于就会发送失败,当 exception 不等于 null 时,执行以下代码

2.png如果代码中有代码是灰色,可以通过 alt+回车 替换一个代码。学习 Scalar 时,基本使用符号。

如下建立分区

3.png

发送方向改为 second,将代码打印,运行数据,结果如下

4.png

分区内偏移量是自己维护自己,所以出现以上结果。

发送数据是按照0123456789发送,读取数据变成0369147258,是因为在一次获取数据的时候,是一个分区数据都拉取之后再继续拉下一个数据。

一个分区消费完了,再紧接着消费下一个分区,所以需要强调分区内有序,而不是整体有序,这是有关消费者消费的问题。

相关文章
|
存储 JavaScript Linux
Crontab详解
Crontab详解
503 0
Crontab详解
|
SQL 流计算 OceanBase
OceanBase CDC从热OB库采集过来的Tinyint(1)类型会默认转换成Boolean,请教一下,如果想转换成int类型,有什方法么?
【2月更文挑战第25天】OceanBase CDC从热OB库采集过来的Tinyint(1)类型会默认转换成Boolean,请教一下,如果想转换成int类型,有什方法么?
345 3
|
12月前
|
程序员 C# 数据库
C# 比较对象新思路,利用反射技术打造更灵活的比较工具
中途接手的项目,碰到需要在更新对象信息时比较并记录差异的需求,最变态的还有附加要求,怎么办?有没有既能满足需求又能对项目影响最小的方法呢?分享这个我封装的方法,一个利用反射技术打造的更灵活的比较工具
203 5
|
人工智能 自然语言处理 搜索推荐
[AI Mem0 Platform] 快速开始,为您的AI应用注入长期记忆和个性化能力!
[AI Mem0 Platform] 快速开始,为您的AI应用注入长期记忆和个性化能力!
1045 0
|
Linux
linux如何去掉目录背景颜色
linux如何去掉目录背景颜色
527 2
|
算法 网络协议 Python
python比较TCP_NODELAY启用与否的耗时
Nagle算法是TCP中的一种流量控制算法,它会将小的数据包合并成大的数据包,减少TCP数据包传输的开销,提高网络传输的效率。但是,Nagle算法会将ACK响应延迟一段时间,导致并不是每个数据包到达服务端都会立即得到响应。对于实时性要求较高的应用,可以禁用Nagle算法,从而使得数据包能够及时到达服务端并立即得到响应。
461 0
|
算法 安全 编译器
【C++进阶】模板进阶与仿函数:C++编程中的泛型与函数式编程思想
【C++进阶】模板进阶与仿函数:C++编程中的泛型与函数式编程思想
|
PHP 数据库 数据安全/隐私保护
帝国cms仿鳄鱼下载站网站源码(已测试)
帝国cms仿鳄鱼下载站网站源码(已测试)
337 10
|
监控 前端开发 网络协议
HTTP - 长连接 & 短连接 & 长轮询 & 短轮询 & 心跳机制
HTTP - 长连接 & 短连接 & 长轮询 & 短轮询 & 心跳机制
3404 0
HTTP - 长连接 & 短连接 & 长轮询 & 短轮询 & 心跳机制
|
C语言 C++
C++ string 基本用法
C++ string 基本用法