AbsaOSS / AbsaOSS/ABRiS

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

Aberta
#188 5 comentários 0 reações 0 responsáveis Ver no GitHub
question
Linguagem predominante
Scala
Estrelas
242
Forks
84
Merge médio
10h 12min
PRs com merge (30d)
2

Descrição

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!

Guia de contribuição

Nenhum guia de contribuição indexado para este repositório

Avaliação

Esta issue ainda não foi avaliada.

Receba novas issues na sua caixa de entrada

Um resumo curto de issues do GitHub para quem está começando.