TOP

Kafka学习笔记 --- bootstrap-servers 和 broker.list区别
2019-01-06 02:26:55 】 浏览:812
Tags:Kafka 学习 笔记 --- bootstrap-servers broker.list 区别

版权声明:学习交流为主,未经博主同意禁止转载,禁止用于商用。 https://blog.csdn.net/u012965373/article/details/74648225

在使用的时候会用到bootstrap,与broker.list

本以为是两个参数,其实是实现一个功能,查看源代码后发现broker.list是旧版本命令


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


现在直接可以使用新版本命令bootstrap。




Kafka学习笔记 --- bootstrap-servers 和 broker.list区别 https://www.cppentry.com/bencandy.php?fid=120&id=202723

】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇javaAPI使用kafka0.11,生产者与消.. 下一篇docker——kafka-manager安装