1. Introduction
-
默认:消费者从作为给定分区的领导者的broker中读取;
-
若有多个数据中心,若要为跨数据中心的网络流量计费,
如aws,那可能面临高延迟和高昂的网络费用;
-
从Kafka V2.4,可配置消费者从最近的副本读取,可减少延迟和降低网络成本;
# Broker Setting
rack.id = dataCentreId
replica.selector.class = org.apache.kafka.common.replica.RackAwareReplicaSelector
# Consumer Client Setting
# client.rack设置为消费者启动的数据中心Id
client.rack=dataCentreId