Update Kafka.md

pull/9/head
hmao 5 years ago committed by GitHub
parent 00d5d44533
commit a16f199ee3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -1,10 +1,10 @@
Kafka:
__consumer_offsets 如果你曾经惊讶于 Kafka 日志路径下冒出很多 __consumer_offsets-xxx 这样的目录,那么现在应该明白了吧,这就是 Kafka 自动帮你创建的位移主题啊。
位移主题分区 offsets.topic.num.partitions 它的默认值是 50
位移主题的 Key 中应该保存 3 部分内容:<Group ID, > [groupId,topicName,partitionNumber]
副本数或备份因子 offsets.topic.replication.factor 它的默认值是 3
enable.auto.commit如果值是 true则 Consumer 在后台默默地为你定期提交位移
## Kafka:
### __consumer_offsets 如果你曾经惊讶于 Kafka 日志路径下冒出很多 __consumer_offsets-xxx 这样的目录,那么现在应该明白了吧,这就是 Kafka 自动帮你创建的位移主题啊。
#### 位移主题分区 offsets.topic.num.partitions 它的默认值是 50
#### 位移主题的 Key 中应该保存 3 部分内容:<Group ID, > [groupId,topicName,partitionNumber]
#### 副本数或备份因子 offsets.topic.replication.factor 它的默认值是 3
#### enable.auto.commit如果值是 true则 Consumer 在后台默默地为你定期提交位移
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.
#### Log Compaction 策略来删除位移主题中的过期消息: The idea behind log compaction is selectively remove records where we have most recent update with the same primary key.

Loading…
Cancel
Save