【kafka源码】kafka内部的一些术语

自己阅读kafka源码时的一些记录，更多内容见: https://github.com/pierre94/kafka-notes/blob/master/kafka术语.md

• Abort 中止
• expires到期失效

请求超时等场景用到

• Thunk 一个回调以及传递给它的关联FutureRecordMetadata参数。

A callback and the associated FutureRecordMetadata argument to pass to it.

• drain 排空

RecordAccumulator中将缓存的ProducerBatch排空，并整理成按节点对应的列表 Map<Integer, List<ProducerBatch>>

• Mute 静音

mute all the partitions drained 如果需要保证消息的强顺序性(maxInflightRequests == 1)，则缓存对应 topic 分区对象，防止同一时间往同一个 topic 分区发送多条处于未完成状态的消息。 实际上就是将本批次消息所在的分区信息添加到一个集合中，不能再往这个分区里排空数据，以保障每个topic下的该分区只有一个批次发送

• collated 整理

Map<Integer, List<ProducerBatch>> collateddrain后生成 经过整理的数据集

• magic 消息格式

A record batch is a container for records. In old versions of the record format (versions 0 and 1)