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 通訊了。