Облачный поток Spring org.springframework.cloud.stream.schema.avro.AvroSchemaRegistryClientMessageConverter использует сообщение формат значения заголовка contentType для проверки схемы во время десериализации (resolveWriterSchemaForDeserialization), в то время как io.confluent.kafka.serializers.KafkaAvroSerializer отправляет идентификатор схемы как часть полезной нагрузки и не следует аналогичному подходу формата значения заголовка contentType.
Означает ли это, что поддержка реестра схемы весеннего облачного потока (слияния) ограничена развертываниями, в которых и Производитель, и Потребитель используют средства связывания Кафки весеннего облачного потока?
Какие предложения были бы предложены для случаев, когда в Producer не включен механизм связывания kafka для весеннего облачного потока и включен spring-kafka + KafkaAvroSerializer с включенным реестром схемы, но потребитель использует поддержку схемы потокового весеннего облака?
Спасибо