spark和kafka之间的版本兼容性

问题描述

我正在将Spring Boot从1.5升级到2.3,将kafka从0.11.0.3升级到2.5.0,spark 1.6.3与kafka 2.5.0兼容吗?

解决方法

Spark 2.3+已升级其内部Kafka客户端并弃用了Spark Streaming;我建议升级,而不要声明对kafka-clients的显式依赖,因为它已包含在spark-sql-kafka依赖中。

低于0.10.2的Kafka客户端将继续针对较新的经纪人发挥基本功能。

相关问答

依赖报错 idea导入项目后依赖报错,解决方案:https://blog....
错误1:代码生成器依赖和mybatis依赖冲突 启动项目时报错如下...
错误1:gradle项目控制台输出为乱码 # 解决方案:https://bl...
错误还原:在查询的过程中,传入的workType为0时,该条件不起...
报错如下,gcc版本太低 ^ server.c:5346:31: 错误:‘struct...