1. 程式人生 > >Kafka學習筆記 --- bootstrap-servers 和 broker.list區別

Kafka學習筆記 --- bootstrap-servers 和 broker.list區別

在使用的時候會用到bootstrap,與broker.list

本以為是兩個引數,其實是實現一個功能,檢視原始碼後發現broker.list是舊版本命令


val bootsrapServers = {
if(properties.containsKey("metadata.broker.list"))
warn("Kafka producer configuration contains 'metadata.broker.list'. This configuration is deprecated . Samza has been upgraded " +
"to use Kafka's new producer API. Please update your configurations based on the documentation at http://kafka.apache.org/documentation.html#newproducerconfigs")
Option(properties.get("bootstrap.servers"))
.getOrElse(throw new SamzaException("No bootstrap servers defined in config for %s." format systemName))
.asInstanceOf[String]


現在直接可以使用新版本命令bootstrap。
--------------------- 
0.8 以前,消費進度是直接寫到 zookeeper 的,consumer 必須知道 zookeeper 的地址。這個方案有效能問題,0.9 的時候整體大改了一次,brokers 接管了消費進度,consumer 不再需要和 zookeeper 通訊了。