Valentin comments

Repositories
Issues
Comments

Results 2 comments of


                                            Valentin

Failed to construct kafka consumer due to the Kafka client code does not currently support obtaining a password from the user

hi @sahabcse I faced the same issue after applying steps from the instruction. This error means that Kafka client cannot find the .keytab in HDFS which is unforunately happens in...

How pass commonParams in PySpark?

hi @luisfsantana, If you use Structured Streaming in Python then following code works: ``` lines = spark \ .readStream \ .format("kafka") \ .option("kafka.bootstrap.servers", KAFKA_BOOTSTRAP_SERVER) \ .option("kafka.security.protocol", "SASL_SSL") \ .option("kafka.sasl.kerberos.service.name", "kafka")...