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?