AbsaOSS / AbsaOSS/ABRiS

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

Abierto
#188 5 comentarios 0 reacciones 0 asignados Ver en GitHub
question
Lenguaje dominante
Scala
Estrellas
242
Forks
84
Merge medio
10 h 12 min
PR fusionados (30 d)
2

Descripción

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!

Guía de contribución

No hay ninguna guía de contribución indexada para este repositorio

Evaluación

Este issue todavía no se ha evaluado.

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.