SubjectNamePrefix и subjectNamingStrategy для нескольких схем avro в облачном потоке Spring с объединенным реестром схем - PullRequest
Новая
       73

SubjectNamePrefix и subjectNamingStrategy для нескольких схем avro в облачном потоке Spring с объединенным реестром схем

0 голосов
/ 20 июня 2020

Я работаю над приложением Spring Cloud Stream, и мне нужно зарегистрировать несколько схем в реестре конфлюентных схем. Это отлично работает, если я хочу зарегистрировать только одну схему: 

spring:
  cloud:
    stream:
      schemaRegistryClient:
        endpoint: http:/localhost:8081
    schema:
      avro:
        schema-locations: classpath:avro/schema1.avsc
        subjectNamePrefix: topic1-value
        subjectNamingStrategy: org.springframework.cloud.schema.registry.avro.SubjectPrefixOnlyNamingStrategy

Кроме того, я тестировал несколько схем, которые можно зарегистрировать, как показано ниже: 

schema:
      avro:
        schema-locations:
        - classpath:avro/schema1.avsc
        - classpath:avro/schema2.avsc

Но тогда не удалось установите subjectNamePrefix и subjectNamingStrategy, поскольку они принимают только одну строку!

Есть ли какое-либо решение или обходной путь, чтобы добиться этого?

...