在server.properties
中配置:
# 自动创建主题
auto.create.topics.enable=true
# 默认主题的分区数
num.partitions=8
# 默认分区副本
default.replication.factor=3
注意:default.replication.factor
:默认分区副本数不得超过kafka节点数(你想,副本数如果一个节点放2份,意义就没了)
每个节点都需要配置,然后重启即可。
更多配置参考:Kafka Broker配置
在server.properties
中配置:
# 自动创建主题
auto.create.topics.enable=true
# 默认主题的分区数
num.partitions=8
# 默认分区副本
default.replication.factor=3
注意:default.replication.factor
:默认分区副本数不得超过kafka节点数(你想,副本数如果一个节点放2份,意义就没了)
每个节点都需要配置,然后重启即可。
更多配置参考:Kafka Broker配置
如果3个broker,分区副本也设置为3个,这样能达到负载均衡的目的吗?这样每一生产一份数据,不是3台机器同时都写入了一份相同的数据吗?这样的话只是保证了Kafka的高可用,而不是负载均衡对吗?
是的,保证了Kafka的高可用。
"分区副本也设置为3个" 老哥你这句话是什么意思?分区3个,副本3个的意思吗?
多个Partition满足负载均衡,多个Replication满足高可用。