Простой пример структурированной потоковой передачи Apache Spark с classNotFound: range

Question

Я пытаюсь запустить простой пример структурированной потоковой передачи с веб-сайта Apache Spark.

Я подаю свое заявление в Spark следующим образом:

spark-submit --packages org.apache.spark:spark-sql-kafka-0-10_2.11:2.2.0 spark_structured_streaming.py 

Я использую последнюю версию Spark.

spark-submit --version
Welcome to
      ____              __
     / __/__  ___ _____/ /__
    _\ \/ _ \/ _ `/ __/  '_/
   /___/ .__/\_,_/_/ /_/\_\   version 2.2.0

Но я получаю исключение:

org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
...
Caused by: org.apache.kafka.common.KafkaException: range ClassNotFoundException exception occured
...
Caused by: java.lang.ClassNotFoundException: range

Что я делаю неправильно? Я не нашел много в Интернете. В этой теме написано

Возвращаясь к 0,8 потребительских работ.

Что подразумевается под этим?