Per-record basis schema registry subject name for writing to Kafka
オープン
question
- 主要言語
- Scala
- スター
- 242
- フォーク
- 84
- 平均マージ
- 10時間 12分
- マージ済み PR(30日)
- 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 はまだ評価されていません。