目前，我有以下几个方面

+-------+--------------------+-----+
|    key|          created_at|count|
+-------+--------------------+-----+
|Bullish|[2017-08-06 08:00...|   12|
|Bearish|[2017-08-06 08:00...|    1|
+-------+--------------------+-----+

我使用以下方法将数据流传输到Kafka

df.selectExpr("CAST(key AS STRING) AS key", "to_json(struct(*)) AS value")
  .writeStream
  .format("kafka")
  .option("kafka.bootstrap.servers", "localhost:9092").option("topic","chart3").option("checkpointLocation", "/tmp/checkpoints2")
  .outputMode("complete")
  .start()

这里的问题是，对于dataframe中的每一行，它都会逐一写入kafka。我的消费者会一个接一个地得到信息。
是否有任何方法可以将所有行合并到一个数组中并流式传输到kafka，这样我的消费者就可以一次性获得整个数据。
谢谢你的建议。