Long Segment BaseOffset

下面的例子只是各拿一个做举例，不是全部场景，不要以为logStartOffset，LogEndOffset，HW，LW只有三个场景可以修改 这里需要针对logStartOffset和LogEndOffset做特殊说明，要不会让大家脑袋混乱，并且前言后的章节讲的都是主题分区级别的 1、logStartOffset 对于每个分区中每一个副本(包括Leader和Follower)都有一个独立的值，Kafka服务器记录并管理 如果是单个segment，那logStartOffset是segment的第一个offset位点，如果是多个segment，则是最旧的segment的第一个offset位点， 会受到生产者的写入、管理员的管理等因素的影响(删除oldSegment等) 针对每个消费者组内的每个分区而言的，对于每个消费者组内的每个分区都有一个独立的值，表示消费者在加入消费组之前已经消费的最大偏移量。 客户端记录并管理的，它表示该消费者在消费时的起始位置 会根据消费者消费的情况而不断变化 2、LogEndOffset...

来源：君哥聊技术 Kafka 是一款性能非常优秀的消息队列，每秒处理的消息体量可以达到千万级别。今天来聊一聊 Kafka 高性能背后的技术原理。 1 批量发送 Kafka 收发消息都是批量进行处理的。我们看一下 Kafka 生产者发送消息的代码： private Future<RecordMetadata> doSend(ProducerRecord<K, V> record, Callback callback) { TopicPartition tp = null; try { //省略前面代码 Callback interceptCallback = new InterceptorCallback<>(callback, this.interceptors, tp); //把消息追加到之前缓存的这一批消息上 RecordAccumulator.RecordAppendResult result = accumulator.append(tp, timestamp, serializedKey, serializedValue, headers,...