Details
-
Question
-
Status: Resolved
-
Major
-
Resolution: Invalid
-
2.2.0
-
None
-
None
Description
when I use `spark-streaming-Kafka-0-10_2.11` to consume Kafka Topic, the inner version is :
kafka-clients:0.10.0.1, it means that the inner Kafka version is 0.1.0.0.1 ; before our Kafka cluster is 0.10.1, But now we will update the Kafka cluster to 1.0, but the inner dependency is also 0.10.1 ; and read the document which said support 0.10.0 or higher version, It means that the Kafka client does not match Kafka cluster version, I tried, No issue, But I think it's not safe, what could I do ?