Доступ к версии схемы Avro при использовании SpringBoot @KafkaHandler - PullRequest
Новая
       41

Доступ к версии схемы Avro при использовании SpringBoot @KafkaHandler

0 голосов
/ 09 апреля 2020

Я использую SpringBoot Kafka Consumer с десериализацией Avro следующим образом: 

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

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

Могу ли я как-то получить доступ к имени и версии схемы Avro, которые использовались для десериализации сообщения spefi c?

Кажется, он не является частью заголовка сообщения, и я не могу получить к нему доступ через класс ConsumerRecord. Что-нибудь еще как "@Schema", которое я мог бы добавить в список параметров метода?

...