pyspark: как мы можем заставить kafka api_version в KafkaUtils.createDirectStream

Question

direct_kafka_stream = KafkaUtils.createDirectStream(
        ssc=ssc,
        topics=['pdns'],
        kafkaParams={"metadata.broker.list": brokers},
    )

как мы можем настроить kafka api_version в KafkaUtils.createDirectStream