diff --git a/Kafka.md b/Kafka.md index 6ef823c..8f35199 100644 --- a/Kafka.md +++ b/Kafka.md @@ -1,5 +1,6 @@ ## Kafka: -### __consumer_offsets: 如果你曾经惊讶于 Kafka 日志路径下冒出很多 __consumer_offsets-xxx 这样的目录,那么现在应该明白了吧,这就是 Kafka 自动帮你创建的位移主题啊。 +### 生产者消息分区机制原理剖析 +#### __consumer_offsets: 如果你曾经惊讶于 Kafka 日志路径下冒出很多 __consumer_offsets-xxx 这样的目录,那么现在应该明白了吧,这就是 Kafka 自动帮你创建的位移主题啊。 #### 位移主题分区 offsets.topic.num.partitions 它的默认值是 50 #### 位移主题的 Key 中应该保存 3 部分内容: [groupId,topicName,partitionNumber] #### 副本数或备份因子 offsets.topic.replication.factor 它的默认值是 3 @@ -7,4 +8,4 @@ auto.commit.interval.ms:提交间隔 #### Log Compaction 策略来删除位移主题中的过期消息: The idea behind log compaction is selectively remove records where we have most recent update with the same primary key. - +### 生产者压缩算法面面观