程序员笔记 （三十五）Kafka
（一）ProducerRecord
一个ProducerRecord封装了一条待发送的消息(或称为记录)。
ProducerRecord由5个字段构成，它们分别如下
topic:该消息所属的 topic。
partition:该消息所属的分区。
key:消息 key。
value:消息体。
timestamp:消息时间戳
（二）RecordMetadata
该数据结构表示Kafka服务器端返回给客户端的消息的元数据信息，包含如下内容
offset:消息在分区日志中的位移信息。
timestamp:消息时间戳
topic/partition:所属topic的分区。
checksum:消息CRC32码。
serializedKeySize:序列化后的消息 key字节数。
serializedValueSize:序列化后的消息value字节数
（三）
（四）
（五）
（六）
cients端常见的3种消息交付语义。它们分别如下。
最多一次(at mostonce):消息可能丢失也可能被处理，但最多只会被处理一次。
至少一次(atleast once):消息不会丢失，但可能被处理多次。
精确一次(exactlyonce):消息被处理且只会被处理一次。
（七）
Kafka提供了丰富的JMX指标用于实时监控集群运行的健康程度。不过若要使用它们，用户必须在启动 broker前就首先设置JMX端口。
（八）Kafka 集群的升级
如果您发现该资源为电子书等存在侵权的资源或对该资源描述不正确等，可点击“私信”按钮向作者进行反馈；如作者无回复可进行平台仲裁，我们会在第一时间进行处理！
- 最近热门资源
- 银河麒麟桌面操作系统V10SP1-2403-update1版本中，通过“麒麟管家-设备管理-硬件信息-硬盘”查看硬盘类型时，显示的是HDD（机械硬盘），而实际上该笔记本的硬盘类型为SSD 81
- 以openkylin为例编译安装内核 77
- 分享解决宏碁电脑关机时自动重启的方法 73
- 统信uosboot区分未挂载导致更新备份失败 63
- 分享如何解决报错：归档 xxx.deb 对成员 control.tar.zst 使用了未知的压缩，放弃操作 63
- 统信uos安装mysql的实例参考 60
- 格之格打印机dp3300系列国产系统uos打印机驱动选择 57
- 在银河麒麟高级服务器操作系统V10SP3中，需要将默认shell类型修改为csh。 51
- MySQL国产平替最佳选择---万里数据库（GreatDB） 45
- 最近下载排行榜
- 银河麒麟桌面操作系统V10SP1-2403-update1版本中，通过“麒麟管家-设备管理-硬件信息-硬盘”查看硬盘类型时，显示的是HDD（机械硬盘），而实际上该笔记本的硬盘类型为SSD 0
- 以openkylin为例编译安装内核 0
- 分享解决宏碁电脑关机时自动重启的方法 0
- 统信uosboot区分未挂载导致更新备份失败 0
- 分享如何解决报错：归档 xxx.deb 对成员 control.tar.zst 使用了未知的压缩，放弃操作 0
- 统信uos安装mysql的实例参考 0
- 格之格打印机dp3300系列国产系统uos打印机驱动选择 0
- 在银河麒麟高级服务器操作系统V10SP3中，需要将默认shell类型修改为csh。 0
- MySQL国产平替最佳选择---万里数据库（GreatDB） 0
prtyaa 收益400.83元
zlj141319 收益237.91元
哆啦漫漫喵 收益231.52元
IT-feng 收益219.92元
1843880570 收益214.2元
风晓 收益208.24元
777 收益173.17元
Fhawking 收益106.6元
信创来了 收益106.03元
克里斯蒂亚诺诺 收益91.08元
