Sorry, typo. Should be a repartition not a groupBy.
> spark.readStream
> .format("kafka")
> .option("kafka.bootstrap.servers", "...")
> .option("subscribe", "t0,t1")
> .load()
> .repartition($"partition")
> .writeStream
> .foreach(... code to write to cassandra ...)
>
