AbsaOSS / AbsaOSS/ABRiS

Per-record basis schema registry subject name for writing to Kafka

未关闭
#188 5 条评论 0 个 reaction 已指派 0 人 在 GitHub 查看
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 还没有评估数据。

把新 issue 发到你的邮箱

精选适合新手参与的 GitHub issue 摘要。