在CentOS上配置Kafka的存儲主要涉及修改Kafka的配置文件server.properties
。以下是一些關鍵的存儲配置項:
broker.id:
broker.id=0
log.dirs:
log.dirs=/tmp/kafka-logs,/var/lib/kafka-logs
log.retention.hours:
log.retention.hours=168
log.retention.bytes:
log.retention.bytes=1073741824
log.segment.bytes:
log.segment.bytes=1073741824
log.flush.interval.messages:
log.flush.interval.messages=10000
log.flush.interval.ms:
log.flush.interval.ms=30000
num.partitions:
num.partitions=8
default.replication.factor:
default.replication.factor=3
min.insync.replicas:
min.insync.replicas=2
unclean.leader.election.enable:
unclean.leader.election.enable=false
log.cleanup.policy:
delete
或compact
。log.cleanup.policy=delete
log.cleanup.interval.mins:
log.cleanup.interval.mins=15
zookeeper.connect:
zookeeper.connect=localhost:2181
offsets.topic.replication.factor:
offsets.topic.replication.factor=3
transaction.state.log.replication.factor:
transaction.state.log.replication.factor=3
transaction.state.log.min.isr:
transaction.state.log.min.isr=2
這些配置項可以根據你的具體需求進行調整。修改配置文件后,需要重啟Kafka服務以使更改生效。你可以使用以下命令來重啟Kafka:
sudo systemctl restart kafka
或者如果你使用的是init.d腳本:
sudo service kafka restart
請確保在修改配置之前備份原始的server.properties
文件,以便在需要時可以恢復。