Access to Avro schema version when using SpringBoot @KafkaHandler

Viewed 189

I'm using a SpringBoot Kafka Consumer with Avro Deserialization like this:

Service
@KafkaListener(topics = ["\${app.topics.foo}"])
class FooConsumer(private val fooImportService: FooImportService) {

    @KafkaHandler
    fun consume(@Payload fooKopf: FooKopf, @Header(name = "X-Foo") foo: String) {
        // ...
    }

Can I somehow access the Avro Schema name and version that was used to deserialize a spefic message?

It seems not to be part of the message Header nor can I access it via the ConsumerRecord class. Anything else like "@Schema" that I could add to the method parameter list?

0 Answers
Related