โ06-25-2021 08:06 AM
Yes we can using below code snippet
spark
.readStream
.format("kafka")
.option("kafka.bootstrap.servers", "host1:port1,host2:port2")
.option("subscribePattern", "topic.*")
.load()
never-displayed
Passionate about hosting events and connecting people? Help us grow a vibrant local communityโsign up today to get started!