Per-record basis schema registry subject name for writing to Kafka
未关闭
question
- 主要语言
- Scala
- 星标
- 242
- 派生
- 84
- 平均合并
- 10 小时 12 分钟
- 30 天内合并 PR
- 2
描述
Spark allows creating a column named `topic` to define a per-record basis topic.
> The destination topic for the records of the DataFrame can either be specified statically as an option to the DataStreamWriter or on a per-record basis as a column named “topic” in the DataFrame. ([Source](https://databricks.com/blog/2017/04/26/processing-data-in-apache-kafka-with-structured-streaming-in-apache-spark-2-2.html))
I need to use the same strategy for the schema registry subject name. Does ABRiS support it?
Thanks!
贡献指南
这个仓库没有索引到贡献指南
评估
这个 Issue 还没有评估数据。