【问题标题】:spark streaming + kafka compatibility issue火花流 + kafka 兼容性问题
【发布时间】:2018-12-01 16:29:47
【问题描述】:

火花流是否与 0.8.2.1 以上的 kafka 版本兼容? 编写自定义接收器是使火花流使用 0.9 以上版本的 kafka 的唯一选择吗?

【问题讨论】:

    标签: apache-spark apache-kafka spark-streaming spark-streaming-kafka


    【解决方案1】:

    我刚刚在 server.properties 文件中添加了“inter.broker.protocol.version=CURRENT_KAFKA_VERSION(例如 0.8.2 或 0.9.0.0)”。这将使旧的 0.8.2.1 消费者能够从新版本的 kafka 代理接收数据。

    【讨论】:

      猜你喜欢
      • 2017-10-22
      • 2019-10-11
      • 2017-04-27
      • 1970-01-01
      • 2020-06-21
      • 2015-10-13
      • 2020-03-10
      • 2019-03-30
      • 2018-12-22
      相关资源
      最近更新 更多