Re: Can we subscribe to pattern of topics(Kafka) f...

Srikanth_Gupta_ · ‎06-25-2021

Srikanth_Gupta_ · ‎06-25-2021

Yes we can using below code snippet

spark

.readStream

.format("kafka")

.option("kafka.bootstrap.servers", "host1:port1,host2:port2")

.option("subscribePattern", "topic.*")

.load()

Can we subscribe to pattern of topics(Kafka) from Structured streaming