Hi, I'm trying out Structured Streaming from current 2.0 branch. Does the branch currently support Kafka as either source or sink? I couldn't find a specific JIRA or design doc for that in SPARK-8360 or in the examples... Is it still targeted for 2.0?
Also, I naively assume it will look similar to hdfs or JDBC *stream("path")*, where the path will be some sort of Kafka URI (maybe protocol + broker list + topic list). Is that the current thinking? Thanks, Ofir Manor Co-Founder & CTO | Equalum Mobile: +972-54-7801286 | Email: ofir.ma...@equalum.io