How to setup confluent Kafka. df = (spark_session .readStream .format("kafka") .option("kafka.bootstrap.servers", confluentBootstrapServers) .option("kafka.security ...
INSERT INTO Worker Values('Vishal','Rathore','vishalrathore@ineuron.com','Finance', 45000,'2018-02-12') INSERT INTO Worker Values('Rahul','Sarathe','rahulsarathe ...