Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
04-19-2022 02:29 PM
Okay figured the problem. So it works only if I use the .option("kafka.sasl.jaas.config", EH_SASL)
Doesn't work when I specify the same details as
option("kafka.sasl.username", “myuser”)
.option("kafka.sasl.password", “mypwd”)
