开发者学堂课程【分布式消息系统 Kafka 快速入门:带回调函数的生产者】学习笔记,与课程紧密联系,让用户快速学习知识。
课程地址:https://developer.aliyun.com/learning/course/98/detail/1611
带回调函数的生产者
一、 发送数据
发送方法有两个,其中 callback 是一个接口,接口可以被直接使用,将它的实现方法写出即可。
每次发送一条数据之后都会回到以下方法。
其中 recordmetadata 是源数据信息
需要将其打印就需要判断 exception 是否等于 null,如果不等于就会发送失败,当 exception 不等于 null 时,执行以下代码
如果代码中有代码是灰色,可以通过 alt+回车 替换一个代码。学习 Scalar 时,基本使用符号。
如下建立分区
发送方向改为 second,将代码打印,运行数据,结果如下
分区内偏移量是自己维护自己,所以出现以上结果。
发送数据是按照0123456789发送,读取数据变成0369147258,是因为在一次获取数据的时候,是一个分区数据都拉取之后再继续拉下一个数据。
一个分区消费完了,再紧接着消费下一个分区,所以需要强调分区内有序,而不是整体有序,这是有关消费者消费的问题。