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

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

开发者学堂课程【分布式消息系统 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,是因为在一次获取数据的时候,是一个分区数据都拉取之后再继续拉下一个数据。

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

相关文章
|
6月前
|
消息中间件 监控 JavaScript
消息队列和事件循环
消息队列和事件循环
74 0
|
消息中间件 存储 监控
消息队列与任务队列的区别
消息队列和任务队列是我们在软件系统中常常遇到的概念。尽管它们的名字相似,但实际上它们有不同的用途和工作原理。本文将介绍消息队列和任务队列之间的区别。
581 0
|
消息中间件 Windows
Windows消息,消息循环的处理,消息队列,键盘消息,鼠标消息,定时器消息(四)
Windows消息,消息循环的处理,消息队列,键盘消息,鼠标消息,定时器消息
|
消息中间件 Windows
Windows消息,消息循环的处理,消息队列,键盘消息,鼠标消息,定时器消息(二)
Windows消息,消息循环的处理,消息队列,键盘消息,鼠标消息,定时器消息
|
消息中间件 Windows
Windows消息,消息循环的处理,消息队列,键盘消息,鼠标消息,定时器消息(三)
Windows消息,消息循环的处理,消息队列,键盘消息,鼠标消息,定时器消息(三)
|
消息中间件 Windows
Windows消息,消息循环的处理,消息队列,键盘消息,鼠标消息,定时器消息(一)
Windows消息,消息循环的处理,消息队列,键盘消息,鼠标消息,定时器消息
|
消息中间件 缓存 负载均衡
RocketMQ中生产者发消息前为啥一定要调用start()方法?
RocketMQ中生产者发消息前为啥一定要调用start()方法?
202 0
RocketMQ中生产者发消息前为啥一定要调用start()方法?
|
消息中间件 缓存 负载均衡
消息发送3-选择队列|学习笔记
快速学习消息发送3-选择队列
消息发送3-选择队列|学习笔记