Register Avro schema using kafka sink

[lucakuendig]

Hi community I am struggling to understand what the configuration encoding.avro.schema for the kafka sink exactly does. Is it actually just validating the event against that schema and then sending it or should it also register the schema with the schema registry?

I have not really found an answer to this anywhere but from what I found I guess it is currently not possible to register the schema automatically when using the kafka sink?

[pront]

Hi @lucakuendig, I suppose you are referring to the https://vector.dev/docs/reference/configuration/sinks/kafka/#encoding.avro.schema option. This option is used to specify the actual schema as a string. This string is later parsed into an actual Schema which is used to encode Vector events to requests that the downstream Kafka consumer can understand.