Spark Structured Streaming Kafka Writer 是否支持将数据写入特定分区？
Does Spark Structured Streaming Kafka Writer supports writing data to particular partition?
Spark Structured Streaming的Kafka Writer是否支持向特定分区写入数据？ Spark Structured Streaming Documentation中没有提到不支持向特定分区写入数据。
此外，我在部分中看不到传递 "partition id" 的选项
"Writing Data to Kafka"
如果不支持，任何未来的支持计划或不支持的原因。
密钥决定写入哪个分区 - 不，您不能在 Spark 的写入方法中对分区值进行硬编码。
Spark 确实允许您配置 kafka.partitioner.class，但是，这将允许您根据数据的键定义分区号
Kafka’s own configurations can be set via DataStreamReader.option with kafka. prefix, e.g, stream.option("kafka.bootstrap.servers", "host:port"). For possible kafka parameters, see ... Kafka producer config docs for parameters related to writing data.
Spark Structured Streaming的Kafka Writer是否支持向特定分区写入数据？ Spark Structured Streaming Documentation中没有提到不支持向特定分区写入数据。
此外，我在部分中看不到传递 "partition id" 的选项 "Writing Data to Kafka"
如果不支持，任何未来的支持计划或不支持的原因。
密钥决定写入哪个分区 - 不，您不能在 Spark 的写入方法中对分区值进行硬编码。
Spark 确实允许您配置 kafka.partitioner.class，但是，这将允许您根据数据的键定义分区号
Kafka’s own configurations can be set via
DataStreamReader.optionwithkafka.prefix, e.g,stream.option("kafka.bootstrap.servers", "host:port"). For possible kafka parameters, see ... Kafka producer config docs for parameters related to writing data.