cancel
Showing results for 
Search instead for 
Did you mean: 
Machine Learning
cancel
Showing results for 
Search instead for 
Did you mean: 

Forum Posts

wchen
by New Contributor II
  • 5435 Views
  • 7 replies
  • 2 kudos

Resolved! In Databricks, the Python kafka consumer app in notebook to Confluent Cloud having the issue captured in the Body of question: SASL/PLAIN authentication being used

kafkashaded.org.apache.kafka.common.KafkaException: Failed to construct kafka consumer at kafkashaded.org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:823) at kafkashaded.org.apache.kafka.clients.consumer.KafkaConsumer.<init>...

  • 5435 Views
  • 7 replies
  • 2 kudos
Latest Reply
bigdata70
New Contributor III
  • 2 kudos

@Kaniz Fatma​ I am having the same issue.%python import pyspark.sql.functions as fn from pyspark.sql.types import StringType   binary_to_string = fn.udf(lambda x: str(int.from_bytes(x, byteorder='big')), StringType())   df = spark.readStream.format("...

  • 2 kudos
6 More Replies
Labels