1. Introduction

  • 默认:消费者从作为给定分区的领导者的broker中读取;

  • 若有多个数据中心,若要为跨数据中心的网络流量计费,
    如aws,那可能面临高延迟和高昂的网络费用;

ClosestReplicaA
  • 从Kafka V2.4,可配置消费者从最近的副本读取,可减少延迟和降低网络成本;

ClosestReplicaB
# Broker Setting
rack.id = dataCentreId

replica.selector.class = org.apache.kafka.common.replica.RackAwareReplicaSelector

# Consumer Client Setting

# client.rack设置为消费者启动的数据中心Id
client.rack=dataCentreId